diff --git a/pkg/kubelet/pod_workers_test.go b/pkg/kubelet/pod_workers_test.go index 32c8b3ce38b..976cd25bdb6 100644 --- a/pkg/kubelet/pod_workers_test.go +++ b/pkg/kubelet/pod_workers_test.go @@ -1637,7 +1637,8 @@ func TestSyncKnownPods(t *testing.T) { // verify workers that are not terminated stay open even if config no longer // sees them podWorkers.SyncKnownPods(nil) - if len(podWorkers.podUpdates) != 2 { + drainAllWorkers(podWorkers) + if len(podWorkers.podUpdates) != 0 { t.Errorf("Incorrect number of open channels %v", len(podWorkers.podUpdates)) } if len(podWorkers.podSyncStatuses) != 2 {