summaryrefslogtreecommitdiffstats
path: root/src/orchestrator
diff options
context:
space:
mode:
authorMatthias Beyer <mail@beyermatthias.de>2020-11-14 14:37:20 +0100
committerMatthias Beyer <mail@beyermatthias.de>2020-11-14 18:18:27 +0100
commit056a2c66e3d3fc8c4b6803acb9d151673b78a23f (patch)
tree532f8970c61f147af3dcde496953ef1a50844b0a /src/orchestrator
parent2de687ac49c1d9aa48334d9cc0550f65ddfc96f3 (diff)
Add debug output, error context information
Signed-off-by: Matthias Beyer <mail@beyermatthias.de>
Diffstat (limited to 'src/orchestrator')
-rw-r--r--src/orchestrator/orchestrator.rs5
1 files changed, 1 insertions, 4 deletions
diff --git a/src/orchestrator/orchestrator.rs b/src/orchestrator/orchestrator.rs
index 6d8ff11..33dcd1f 100644
--- a/src/orchestrator/orchestrator.rs
+++ b/src/orchestrator/orchestrator.rs
@@ -75,8 +75,6 @@ impl Orchestrator {
let number_of_jobsets = self.jobsets.len();
let database = self.database;
- let multibar = indicatif::MultiProgress::new();
-
for (i, jobset) in self.jobsets.into_iter().enumerate() {
let merged_store = MergedStores::new(self.release_store.clone(), self.staging_store.clone());
@@ -87,7 +85,7 @@ impl Orchestrator {
let job_id = runnable.uuid().clone();
trace!("Runnable {} for package {}", job_id, runnable.package().name());
- let jobhandle = self.scheduler.schedule_job(runnable, &multibar).await?;
+ let jobhandle = self.scheduler.schedule_job(runnable).await?;
trace!("Jobhandle -> {:?}", jobhandle);
// clone the bar here, so we can give a handle to the async result fetcher closure
@@ -127,7 +125,6 @@ impl Orchestrator {
let mut results = results; // rebind!
report_result.append(&mut results);
}
- multibar.join()?;
Ok(report_result)
}