diff --git a/src/backfill.rs b/src/backfill.rs index e3ed6dd..31e6928 100644 --- a/src/backfill.rs +++ b/src/backfill.rs @@ -50,7 +50,9 @@ pub async fn backfill( // wait for the big backfill to finish while let Some(res) = workers.join_next().await { - res??; + res + .inspect_err(|e| log::error!("problem joining source workers: {e}"))? + .inspect_err(|e| log::error!("problem *from* source worker: {e}"))?; } log::info!("finished fetching backfill in {:?}", t_step.elapsed()); Ok(())