From 7458ed01d6aa150b8a6046e0dbeba88d5d5ff1bb Mon Sep 17 00:00:00 2001 From: Monis Khan Date: Thu, 15 Sep 2022 10:33:33 -0400 Subject: [PATCH] Check for context cancellation on each buffered chunk TestListPager_EachListItem flakes without this change. Signed-off-by: Monis Khan --- staging/src/k8s.io/client-go/tools/pager/pager.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/staging/src/k8s.io/client-go/tools/pager/pager.go b/staging/src/k8s.io/client-go/tools/pager/pager.go index 805859e092b..9ba988f6856 100644 --- a/staging/src/k8s.io/client-go/tools/pager/pager.go +++ b/staging/src/k8s.io/client-go/tools/pager/pager.go @@ -203,6 +203,11 @@ func (p *ListPager) eachListChunkBuffered(ctx context.Context, options metav1.Li }() for o := range chunkC { + select { + case <-ctx.Done(): + return ctx.Err() + default: + } err := fn(o) if err != nil { return err // any fn error should be returned immediately