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