diff --git a/ufos/src/main.rs b/ufos/src/main.rs index 5b82c0f..949db21 100644 --- a/ufos/src/main.rs +++ b/ufos/src/main.rs @@ -116,7 +116,7 @@ async fn go( let rolling = write_store .background_tasks(args.reroll)? .run(args.backfill); - consumer_tasks.spawn(async move { + whatever_tasks.spawn(async move { rolling .await .inspect_err(|e| log::warn!("rollup ended: {e}"))?;