Merge pull request #112476 from enj/enj/i/list_pager_flake

Check for context cancellation on each buffered chunk
This commit is contained in:
Kubernetes Prow Robot
2022-09-15 16:41:32 -07:00
committed by GitHub

View File

@@ -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