From fab35314666ac7a8af7baded8cc2c5860c1e30f5 Mon Sep 17 00:00:00 2001 From: KevinPham-TruffleSecurity Date: Fri, 11 Sep 2026 17:33:47 -0700 Subject: [PATCH] Comments --- pkg/sources/s3/s3.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/sources/s3/s3.go b/pkg/sources/s3/s3.go index 4c085ccd0..921eef9ec 100644 --- a/pkg/sources/s3/s3.go +++ b/pkg/sources/s3/s3.go @@ -647,7 +647,7 @@ func (s *Source) pageChunker( ctx = context.WithValues(ctx, "bucket", metadata.bucket, "page_number", metadata.pageNumber) for objIdx, obj := range metadata.page.Contents { octx := context.WithValues(ctx, "key", *obj.Key, "size", *obj.Size) - // break, not return: the pool must drain before returning so an in-flight + // the pool must drain before returning so an in flight // worker cannot move the checkpoint after the caller rewinds resume state. if common.IsDone(octx) { break