Comments
This commit is contained in:
@@ -647,7 +647,7 @@ func (s *Source) pageChunker(
|
|||||||
ctx = context.WithValues(ctx, "bucket", metadata.bucket, "page_number", metadata.pageNumber)
|
ctx = context.WithValues(ctx, "bucket", metadata.bucket, "page_number", metadata.pageNumber)
|
||||||
for objIdx, obj := range metadata.page.Contents {
|
for objIdx, obj := range metadata.page.Contents {
|
||||||
octx := context.WithValues(ctx, "key", *obj.Key, "size", *obj.Size)
|
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.
|
// worker cannot move the checkpoint after the caller rewinds resume state.
|
||||||
if common.IsDone(octx) {
|
if common.IsDone(octx) {
|
||||||
break
|
break
|
||||||
|
|||||||
Reference in New Issue
Block a user