diff --git a/bin/reth/src/node/mod.rs b/bin/reth/src/node/mod.rs index 656eb8f8b1..9fa7638b85 100644 --- a/bin/reth/src/node/mod.rs +++ b/bin/reth/src/node/mod.rs @@ -335,14 +335,14 @@ impl Command { .await?; // Run consensus engine to completion - let (rx, tx) = oneshot::channel(); + let (tx, rx) = oneshot::channel(); info!(target: "reth::cli", "Starting consensus engine"); ctx.task_executor.spawn_critical("consensus engine", async move { let res = beacon_consensus_engine.await; - let _ = rx.send(res); + let _ = tx.send(res); }); - tx.await??; + rx.await??; info!(target: "reth::cli", "Consensus engine has exited.");