From 5a79b2ea5a7648741042fc118be7d98dffbd4b24 Mon Sep 17 00:00:00 2001
From: Matthias Beyer <matthias.beyer@atos.net>
Date: Tue, 2 Feb 2021 08:02:03 +0100
Subject: Add tracing output

Signed-off-by: Matthias Beyer <matthias.beyer@atos.net>
---
 src/orchestrator/orchestrator.rs | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

(limited to 'src')

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...")),
-- 
cgit v1.2.3