fix(scanner): correct observational usage arguments

This commit is contained in:
马登山
2026-08-23 10:31:42 +08:00
parent 307510749e
commit 82fb0a8843
2 changed files with 2 additions and 2 deletions
+1 -1
View File
@@ -255,7 +255,7 @@ pub(super) fn observational_data_usage_info(
let mut sources = expected_sources.iter().copied().collect::<Vec<_>>();
sources.sort_by_key(|source| (source.pool_index, source.set_index));
for source in sources {
let result = by_source.get(source).copied();
let result = by_source.get(&source).copied();
let current = result.filter(|result| {
result.info.snapshot_complete
&& result.info.next_cycle == scanner_cycle
+1 -1
View File
@@ -392,7 +392,7 @@ impl ScannerIOCycle for ECStore {
observational_data_usage_info(
&results,
&expected_sources,
&all_buckets,
&all_bucket_names,
scan_plan_digest,
want_cycle,
leader_epoch,