[ES-1393569] optimize concurrent strategy with update at

jnyi · jnyi · commit f90f97988c24 · 2025-04-06T11:33:25.000-07:00
Signed-off-by: Yi Jin &lt;yi.jin@databricks.com&gt;
diff --git a/pkg/block/fetcher.go b/pkg/block/fetcher.go
@@ -345,7 +345,7 @@ func (f *ConcurrentLister) GetActiveAndPartialBlockIDs(ctx context.Context, ch c
 		case metaChan <- id:
 		}
 		return nil
-	}); err != nil {
+	}, objstore.WithUpdatedAt()); err != nil {
 		return nil, err
 	}
 	close(metaChan)

Original file line number	Diff line number	Diff line change
`@@ -345,7 +345,7 @@ func (f *ConcurrentLister) GetActiveAndPartialBlockIDs(ctx context.Context, ch c`
`345`	`345`	`case metaChan <- id:`
`346`	`346`	`}`
`347`	`347`	`return nil`
`348`		`- }); err != nil {`
	`348`	`+ }, objstore.WithUpdatedAt()); err != nil {`
`349`	`349`	`return nil, err`
`350`	`350`	`}`
`351`	`351`	`close(metaChan)`