chore: spawn pipeline future to blocking pool (#1418)

This commit is contained in:
Matthias Seitz
2023-02-16 21:22:06 +01:00
committed by GitHub
parent 6005ecb89a
commit b9c8380830

View File

@ -175,7 +175,7 @@ impl Command {
// Run pipeline
let (rx, tx) = tokio::sync::oneshot::channel();
info!(target: "reth::cli", "Starting sync pipeline");
ctx.task_executor.spawn_critical("pipeline task", async move {
ctx.task_executor.spawn_critical_blocking("pipeline task", async move {
let res = pipeline.run(db.clone()).await;
let _ = rx.send(res);
});