We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c86ff10 commit c873181Copy full SHA for c873181
crates/sync/pipeline/src/lib.rs
@@ -422,12 +422,14 @@ where
422
info!(target: "pipeline", checkpoint = %last_block_processed, "New checkpoint set.");
423
}
424
425
+ let min_last_block_processed = last_block_processed_list.into_iter().min();
426
+
427
// Update overall pipeline sync position (minimum checkpoint across all stages)
- if let Some(&min_checkpoint) = last_block_processed_list.iter().min() {
428
+ if let Some(min_checkpoint) = min_last_block_processed {
429
self.metrics.set_sync_position(min_checkpoint);
430
431
- Ok(last_block_processed_list.into_iter().min().unwrap_or(to))
432
+ Ok(min_last_block_processed.unwrap_or(to))
433
434
435
/// Run the pipeline loop.
0 commit comments