Skip to content

Commit c2ed597

Browse files
Update cmd/util/cmd/common/clusters.go
Co-authored-by: Jordan Schalm <[email protected]>
1 parent aab8a5b commit c2ed597

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

cmd/util/cmd/common/clusters.go

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -53,13 +53,19 @@ func ConstructClusterAssignment(log zerolog.Logger, partnerNodes, internalNodes
5353
}
5454

5555
// shuffle partner nodes in-place using the provided randomness
56-
_ = randomSource.Shuffle(len(partnerCollectors), func(i, j int) {
56+
err := randomSource.Shuffle(len(partnerCollectors), func(i, j int) {
5757
partnerCollectors[i], partnerCollectors[j] = partnerCollectors[j], partnerCollectors[i]
5858
})
59+
if err != nil {
60+
log.Fatal().Err(err).Msg("could not shuffle partners")
61+
}
5962
// shuffle internal nodes in-place using the provided randomness
60-
_ = randomSource.Shuffle(len(internalCollectors), func(i, j int) {
63+
err = randomSource.Shuffle(len(internalCollectors), func(i, j int) {
6164
internalCollectors[i], internalCollectors[j] = internalCollectors[j], internalCollectors[i]
6265
})
66+
if err != nil {
67+
log.Fatal().Err(err).Msg("could not shuffle internals")
68+
}
6369

6470
// capture first reference weight to validate that all collectors have equal weight
6571
refWeight := internalCollectors[0].InitialWeight

0 commit comments

Comments
 (0)