We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 80e88a4 commit 0f9f94fCopy full SHA for 0f9f94f
1 file changed
rust/main/lander/src/dispatcher/stages/inclusion_stage.rs
@@ -197,7 +197,10 @@ impl InclusionStage {
197
};
198
loop {
199
tokio::time::sleep(poll_rate).await;
200
- tracing::debug!(domain, "Checking for any payloads needs reprocessing");
+ tracing::debug!(
201
+ domain,
202
+ "Checking for any transactions that needs reprocessing"
203
+ );
204
205
let txs = match state.adapter.get_reprocess_txs().await {
206
Ok(s) => s,
@@ -207,8 +210,8 @@ impl InclusionStage {
207
210
continue;
208
211
}
209
212
213
+ tracing::debug!(?txs, "Reprocessing transactions");
214
let mut locked_pool = pool.lock().await;
-
215
for tx in txs {
216
locked_pool.insert(tx.uuid.clone(), tx);
217
0 commit comments