Skip to content

Commit 600d035

Browse files
committed
cre-1601: better comments
1 parent df7e4e4 commit 600d035

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

pkg/workflows/ring/plugin.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -177,8 +177,8 @@ func (p *Plugin) Outcome(_ context.Context, outctx ocr3types.OutcomeContext, _ t
177177
return nil, err
178178
}
179179

180-
// Use deterministic hashing to assign workflows to shards
181-
// This must be a pure function of consensus-derived data to avoid protocol failures
180+
// Deterministic hashing ensures all nodes agree on workflow-to-shard assignments
181+
// without coordination, preventing protocol failures from inconsistent routing
182182
routes := make(map[string]*pb.WorkflowRoute)
183183
for _, wfID := range allWorkflows {
184184
assignedShard := getShardForWorkflow(wfID, healthyShards)

0 commit comments

Comments
 (0)