We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 934a478 commit 1fd4284Copy full SHA for 1fd4284
crates/sync/pipeline/src/lib.rs
@@ -520,10 +520,11 @@ impl Pipeline {
520
if let Some(tip) = self.tip {
521
let to = current_chunk_tip.min(tip);
522
let iteration_start = std::time::Instant::now();
523
+
524
let last_block_processed = self.execute(to).await?;
- let iteration_duration = iteration_start.elapsed().as_secs_f64();
525
+ self.metrics.set_sync_position(last_block_processed);
526
- // Record pipeline metrics for this iteration
527
+ let iteration_duration = iteration_start.elapsed().as_secs_f64();
528
self.metrics.record_iteration_duration(iteration_duration);
529
530
// Notify subscribers about the newly processed block
0 commit comments