Skip to content

Commit

Permalink
Update cmd/util/cmd/common/clusters.go
Browse files Browse the repository at this point in the history
  • Loading branch information
jordanschalm authored Sep 4, 2024
1 parent 231c2f4 commit da5726e
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion cmd/util/cmd/common/clusters.go
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ func ConstructClusterAssignment(log zerolog.Logger, partnerNodes, internalNodes
if len(partnerCollectors) > 0 && len(partnerCollectors) > 2*len(internalCollectors) {
return nil, nil, fmt.Errorf("requiring at least x>0 number of partner collection nodes and y > 2x number of internal collection nodes, but got x,y=%d,%d", len(partnerCollectors), len(internalCollectors))
}
// sanity check ^ enforces that there is at least one internal node, hence `internalNodes[0].InitialWeight` is always a valid reference weight
// sanity check ^ enforces that there is at least one internal node, hence `internalCollectors[0].InitialWeight` is always a valid reference weight
refWeight := internalCollectors[0].InitialWeight

identifierLists := make([]flow.IdentifierList, numCollectionClusters)
Expand Down

0 comments on commit da5726e

Please sign in to comment.