Skip to content

Commit 6d368ce

Browse files
committed
Rebase priorityqueue shutdown fix for release-0.22
1 parent d04f428 commit 6d368ce

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pkg/controller/priorityqueue/priorityqueue_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -337,7 +337,7 @@ var _ = Describe("Controllerworkqueue", func() {
337337
}()
338338

339339
// Verify the go routine above is now waiting for an item.
340-
Eventually(q.waiters.Load).Should(Equal(int64(1)))
340+
Eventually(q.(*priorityqueue[string]).waiters.Load).Should(Equal(int64(1)))
341341
Consistently(getUnblocked).ShouldNot(BeClosed())
342342

343343
// shut down

0 commit comments

Comments
 (0)