From 3461caee41b2359a976d8e4a0eff36ce50d6997c Mon Sep 17 00:00:00 2001 From: Todd Date: Mon, 13 Feb 2023 02:50:23 -0800 Subject: [PATCH] fix downstream manager test (#2950) --- internal/daemon/cluster/downstreammanager_test.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/daemon/cluster/downstreammanager_test.go b/internal/daemon/cluster/downstreammanager_test.go index 28cf4d54ee..e416360eee 100644 --- a/internal/daemon/cluster/downstreammanager_test.go +++ b/internal/daemon/cluster/downstreammanager_test.go @@ -105,7 +105,7 @@ func TestNewDownstreamManager(t *testing.T) { dm.addConnection("2", w2) got := dm.Connected().UnmappedKeyIds() sort.Strings(got) - assert.Equal(t, []string{"1", "2"}, got) + assert.ElementsMatch(t, []string{"1", "2"}, got) dm.disconnectKeys("1") assert.ErrorIs(t, w1.SetReadDeadline(time.Now()), io.ErrClosedPipe) @@ -189,7 +189,7 @@ func TestNewDownstreamManager(t *testing.T) { dm.mapKeyToWorkerId("1", "w1") dm.mapKeyToWorkerId("2", "w2") - assert.Equal(t, []string{"w1", "w2"}, dm.Connected().WorkerIds()) + assert.ElementsMatch(t, []string{"w1", "w2"}, dm.Connected().WorkerIds()) assert.Empty(t, dm.Connected().UnmappedKeyIds()) assert.NoError(t, w1.SetReadDeadline(time.Now()))