summaryrefslogtreecommitdiffstats
path: root/src/orchestrator/orchestrator.rs
diff options
context:
space:
mode:
authorMatthias Beyer <matthias.beyer@atos.net>2021-06-16 16:26:41 +0200
committerMatthias Beyer <matthias.beyer@atos.net>2021-06-16 16:26:41 +0200
commite680a38fac648516c33562aee3fefbaee1f770a4 (patch)
tree89db454b36015819f97077577c7fc410eeca70d0 /src/orchestrator/orchestrator.rs
parent18f18b4afba7382b99fe3b9be450b3e1c2b21932 (diff)
Add some result inspect() calls for printing trace information
Signed-off-by: Matthias Beyer <matthias.beyer@atos.net>
Diffstat (limited to 'src/orchestrator/orchestrator.rs')
-rw-r--r--src/orchestrator/orchestrator.rs1
1 files changed, 1 insertions, 0 deletions
diff --git a/src/orchestrator/orchestrator.rs b/src/orchestrator/orchestrator.rs
index 0044fb1..113b756 100644
--- a/src/orchestrator/orchestrator.rs
+++ b/src/orchestrator/orchestrator.rs
@@ -375,6 +375,7 @@ impl<'a> Orchestrator<'a> {
let sender = prep.3.into_inner().unwrap_or_else(|| vec![root_sender.clone()]);
JobTask::new(prep.0, prep.1, sender)
})
+ .inspect(|task| trace!("Running: {}", task.jobdef.job.uuid()))
.map(|task| task.run())
.collect::<futures::stream::FuturesUnordered<_>>();
debug!("Built {} jobs", running_jobs.len());