diff --git a/coordinator/src/main.rs b/coordinator/src/main.rs index 2132c56c..3a45a2f3 100644 --- a/coordinator/src/main.rs +++ b/coordinator/src/main.rs @@ -761,6 +761,8 @@ async fn handle_processor_messages<D: Db, Pro: Processors, P: P2p>( ); // If we failed to publish it, restore it batches.push_front(batch); + // Sleep for a few seconds before retrying to prevent hammering the node + tokio::time::sleep(Duration::from_secs(5)).await; } }