@@ -413,6 +413,7 @@ impl SubmitTask {
413
413
) -> eyre:: Result < ControlFlow > {
414
414
let mut retries = 0 ;
415
415
let building_start_time = Instant :: now ( ) ;
416
+
416
417
let ( current_slot, start, end) = self . calculate_slot_window ( ) ;
417
418
debug ! ( current_slot, start, end, "calculating target slot window" ) ;
418
419
@@ -467,9 +468,15 @@ impl SubmitTask {
467
468
} ;
468
469
469
470
// This is reached when `Done` or `Skip` is returned
470
- histogram ! ( "builder.block_build_time" )
471
- . record ( building_start_time. elapsed ( ) . as_millis ( ) as f64 ) ;
472
- info ! ( ?result, "finished block building" ) ;
471
+ let elapsed = building_start_time. elapsed ( ) . as_millis ( ) as f64 ;
472
+ histogram ! ( "builder.block_build_time" ) . record ( elapsed) ;
473
+ info ! (
474
+ ?result,
475
+ tx_count = block. tx_count( ) ,
476
+ block_number = block. block_number( ) ,
477
+ build_time = ?elapsed,
478
+ "finished block building"
479
+ ) ;
473
480
Ok ( result)
474
481
}
475
482
@@ -508,10 +515,9 @@ impl SubmitTask {
508
515
loop {
509
516
// Wait to receive a new block
510
517
let Some ( result) = inbound. recv ( ) . await else {
511
- debug ! ( "upstream task gone" ) ;
518
+ debug ! ( "upstream task gone - exiting submit task " ) ;
512
519
break ;
513
520
} ;
514
-
515
521
debug ! ( block_number = result. block. block_number( ) , "submit channel received block" ) ;
516
522
517
523
// Only attempt each block number once
0 commit comments