@@ -10,6 +10,9 @@ use alloy::{
1010 primitives:: { B256 , U256 } ,
1111 providers:: { Provider , network:: Network } ,
1212} ;
13+ use init4_bin_base:: deps:: {
14+ opentelemetry:: trace:: TraceContextExt , tracing_opentelemetry:: OpenTelemetrySpanExt ,
15+ } ;
1316use signet_constants:: SignetSystemConstants ;
1417use signet_sim:: { HostEnv , RollupEnv } ;
1518use tokio:: { sync:: watch, task:: JoinHandle } ;
@@ -279,13 +282,17 @@ impl EnvTask {
279282 host_block. number = "initial" ,
280283 rollup_header. number = "initial" ,
281284 rollup_header. hash = "initial" ,
285+ trace_id = tracing:: field:: Empty ,
282286 ) ;
283287
284288 while let Some ( rollup_header) = rollup_headers
285289 . next ( )
286290 . instrument ( info_span ! ( parent: & span, "waiting_for_notification" ) )
287291 . await
288292 {
293+ // Ensure that we record the OpenTelemetry trace ID in the span.
294+ span. record ( "trace_id" , span. context ( ) . span ( ) . span_context ( ) . trace_id ( ) . to_string ( ) ) ;
295+
289296 let host_block_number =
290297 self . config . constants . rollup_block_to_host_block_num ( rollup_header. number ) ;
291298 let rollup_block_number = rollup_header. number ;
@@ -360,6 +367,7 @@ impl EnvTask {
360367 host_block. number = host_block_number + 1 ,
361368 rollup_header. number = rollup_block_number + 1 ,
362369 rollup_header. hash = tracing:: field:: Empty ,
370+ trace_id = tracing:: field:: Empty ,
363371 ) ;
364372 }
365373 }
0 commit comments