diff --git a/crates/transaction-pool/src/pool/parked.rs b/crates/transaction-pool/src/pool/parked.rs index b931d83d47..cd8d94f8e9 100644 --- a/crates/transaction-pool/src/pool/parked.rs +++ b/crates/transaction-pool/src/pool/parked.rs @@ -40,7 +40,11 @@ impl ParkedPool { /// If the transaction is already included. pub(crate) fn add_transaction(&mut self, tx: Arc>) { let id = *tx.id(); - assert!(!self.by_id.contains_key(&id), "transaction already included"); + assert!( + !self.by_id.contains_key(&id), + "transaction already included {:?}", + self.by_id.contains_key(&id) + ); let submission_id = self.next_id(); // keep track of size diff --git a/crates/transaction-pool/src/pool/pending.rs b/crates/transaction-pool/src/pool/pending.rs index 1efdde6dec..1a27ba6687 100644 --- a/crates/transaction-pool/src/pool/pending.rs +++ b/crates/transaction-pool/src/pool/pending.rs @@ -97,7 +97,11 @@ impl PendingPool { /// /// if the transaction is already included pub(crate) fn add_transaction(&mut self, tx: Arc>) { - assert!(!self.by_id.contains_key(tx.id()), "transaction already included"); + assert!( + !self.by_id.contains_key(tx.id()), + "transaction already included {:?}", + self.by_id.contains_key(tx.id()) + ); let tx_id = *tx.id(); let submission_id = self.next_id(); diff --git a/crates/transaction-pool/src/pool/txpool.rs b/crates/transaction-pool/src/pool/txpool.rs index b8c684f6f5..c063ef385f 100644 --- a/crates/transaction-pool/src/pool/txpool.rs +++ b/crates/transaction-pool/src/pool/txpool.rs @@ -865,7 +865,7 @@ impl AllTransactions { let pool_tx = PoolInternalTransaction { transaction: transaction.clone(), - subpool: SubPool::Queued, + subpool: state.into(), state, cumulative_cost, };