diff options
author | Matthias Beyer <matthias.beyer@atos.net> | 2021-02-02 08:02:03 +0100 |
---|---|---|
committer | Matthias Beyer <mail@beyermatthias.de> | 2021-02-02 09:47:33 +0100 |
commit | 5a79b2ea5a7648741042fc118be7d98dffbd4b24 (patch) | |
tree | f064a0e538426e72dc0cb709a588c41578496579 /src/orchestrator | |
parent | a6ef6b00e050fad5023cf2ca519e8349c31de45d (diff) |
Add tracing output
Signed-off-by: Matthias Beyer <matthias.beyer@atos.net>
Diffstat (limited to 'src/orchestrator')
-rw-r--r-- | src/orchestrator/orchestrator.rs | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/orchestrator/orchestrator.rs b/src/orchestrator/orchestrator.rs index 00cec75..ecd994a 100644 --- a/src/orchestrator/orchestrator.rs +++ b/src/orchestrator/orchestrator.rs @@ -18,6 +18,7 @@ use anyhow::Result; use anyhow::anyhow; use diesel::PgConnection; use indicatif::ProgressBar; +use log::debug; use log::trace; use tokio::sync::RwLock; use tokio::sync::mpsc::Receiver; @@ -311,11 +312,11 @@ impl<'a> Orchestrator<'a> { } }) .map(|task| task.run()) - .collect::<futures::stream::FuturesUnordered<_>>() - .collect::<Result<()>>(); + .collect::<futures::stream::FuturesUnordered<_>>(); + debug!("Built {} jobs", running_jobs.len()); let multibar_block = tokio::task::spawn_blocking(move || multibar.join()); - let (_, jobs_result) = tokio::join!(multibar_block, running_jobs); + let (_, jobs_result) = tokio::join!(multibar_block, running_jobs.collect::<Result<()>>()); let _ = jobs_result?; match root_receiver.recv().await { None => Err(anyhow!("No result received...")), |