Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion src/config.rs
Original file line number Diff line number Diff line change
Expand Up @@ -215,7 +215,7 @@ impl BuilderConfig {
}

/// Connect to a Flashbots bundle provider.
pub async fn connect_flashbots(&self) -> Result<FlashbotsProvider, eyre::Error> {
pub async fn connect_flashbots(&self) -> Result<FlashbotsProvider> {
self.connect_builder_signer().await.map(|signer| {
ProviderBuilder::new().wallet(signer).connect_http(self.flashbots_endpoint.clone())
})
Expand Down
2 changes: 1 addition & 1 deletion src/tasks/block/sim.rs
Original file line number Diff line number Diff line change
Expand Up @@ -204,7 +204,7 @@ impl SimulatorTask {
let Some(sim_env) = self.envs.borrow_and_update().clone() else { return };

let span = sim_env.span();
span_info!(span, "new block environment received");
span_info!(span, "Starting simulator iteration for new block environment");

// Calculate the deadline for this block simulation.
// NB: This must happen _after_ taking a reference to the sim cache,
Expand Down
24 changes: 15 additions & 9 deletions src/tasks/env.rs
Original file line number Diff line number Diff line change
Expand Up @@ -280,9 +280,11 @@ impl EnvTask {
let mut span = info_span!(
parent: None,
"SimEnv",
host_block.number = "initial",
rollup_header.number = "initial",
rollup_header.hash = "initial",
confirmed_host.number = "initial",
confirmed_ru.number = "initial",
confirmed_ru.hash = "initial",
sim_host.number = "initial",
sim_ru.number = "initial",
trace_id = tracing::field::Empty,
);

Expand All @@ -299,9 +301,11 @@ impl EnvTask {
let rollup_block_number = rollup_header.number;

// Populate span fields.
span.record("host_block.number", host_block_number);
span.record("rollup_header.number", rollup_block_number);
span.record("rollup_header.hash", rollup_header.hash.to_string());
span.record("confirmed_host.number", host_block_number);
span.record("confirmed_ru.number", rollup_block_number);
span.record("confirmed_ru.hash", rollup_header.hash.to_string());
span.record("sim_host.number", host_block_number + 1);
span.record("sim_ru.number", rollup_block_number + 1);

let (host_block_res, quincey_res) = tokio::join!(
self.host_provider
Expand Down Expand Up @@ -365,9 +369,11 @@ impl EnvTask {
// Create a new span for the next iteration.
span = info_span!(
"SimEnv",
host_block.number = host_block_number + 1,
rollup_header.number = rollup_block_number + 1,
rollup_header.hash = tracing::field::Empty,
confirmed_host.number = host_block_number + 1,
confirmed_ru.number = rollup_block_number + 1,
confirmed_ru.hash = tracing::field::Empty,
sim_host.number = host_block_number + 2,
sim_ru.number = rollup_block_number + 2,
trace_id = tracing::field::Empty,
);
}
Expand Down
2 changes: 1 addition & 1 deletion src/tasks/submit/flashbots.rs
Original file line number Diff line number Diff line change
Expand Up @@ -204,7 +204,7 @@ impl FlashbotsTask {
counter!("signet.builder.flashbots.bundles_submitted").increment(1);
debug!(
hash = resp.map(|r| r.bundle_hash.to_string()),
"received bundle hash after submitted to flashbots"
"Submitted MEV bundle to Flashbots, received OK response"
);
}
Err(err) => {
Expand Down