diff --git a/crates/op-rbuilder/src/payload_builder.rs b/crates/op-rbuilder/src/payload_builder.rs index 7535782e..4f3caa18 100644 --- a/crates/op-rbuilder/src/payload_builder.rs +++ b/crates/op-rbuilder/src/payload_builder.rs @@ -1157,6 +1157,7 @@ where // check if the job was cancelled, if so we can exit early if self.cancel.is_cancelled() { + self.record_tx_metrics(num_txs_considered, num_txs_simulated, num_txs_simulated_success, num_txs_simulated_fail); return Ok(Some(())); } @@ -1224,20 +1225,22 @@ where info.executed_senders.push(tx.signer()); info.executed_transactions.push(tx.into_inner()); } + self.record_tx_metrics(num_txs_considered, num_txs_simulated, num_txs_simulated_success, num_txs_simulated_fail); + Ok(None) + } + fn record_tx_metrics(&self, considered: usize, simulated: usize, success: usize, fail: usize) { self.metrics .payload_num_tx_considered - .record(num_txs_considered as f64); + .record(considered as f64); self.metrics .payload_num_tx_simulated - .record(num_txs_simulated as f64); + .record(simulated as f64); self.metrics .payload_num_tx_simulated_success - .record(num_txs_simulated_success as f64); + .record(success as f64); self.metrics .payload_num_tx_simulated_fail - .record(num_txs_simulated_fail as f64); - - Ok(None) + .record(fail as f64); } }