Skip to content

Commit f081485

Browse files
committed
chore: add trace_id to root span
1 parent 712a0da commit f081485

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

src/tasks/env.rs

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -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+
};
1316
use signet_constants::SignetSystemConstants;
1417
use signet_sim::{HostEnv, RollupEnv};
1518
use 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

Comments
 (0)