···5051 // wait for the big backfill to finish
52 while let Some(res) = workers.join_next().await {
53- res??;
0054 }
55 log::info!("finished fetching backfill in {:?}", t_step.elapsed());
56 Ok(())
···5051 // wait for the big backfill to finish
52 while let Some(res) = workers.join_next().await {
53+ res
54+ .inspect_err(|e| log::error!("problem joining source workers: {e}"))?
55+ .inspect_err(|e| log::error!("problem *from* source worker: {e}"))?;
56 }
57 log::info!("finished fetching backfill in {:?}", t_step.elapsed());
58 Ok(())