summaryrefslogtreecommitdiffstats
path: root/src/orchestrator
diff options
context:
space:
mode:
authorMatthias Beyer <mail@beyermatthias.de>2020-11-14 18:09:06 +0100
committerMatthias Beyer <mail@beyermatthias.de>2020-11-14 18:18:27 +0100
commit7eb6359e84e4fea47ca7fe936e9d271c60d081bd (patch)
treefb5106085cbec12191c47142eb37842ad55c65e4 /src/orchestrator
parentfcecf5fce755b2870cf0baae4a29104d146df948 (diff)
Make multi bar available to scheduler when creating job
Signed-off-by: Matthias Beyer <mail@beyermatthias.de>
Diffstat (limited to 'src/orchestrator')
-rw-r--r--src/orchestrator/orchestrator.rs4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/orchestrator/orchestrator.rs b/src/orchestrator/orchestrator.rs
index c486296..010a573 100644
--- a/src/orchestrator/orchestrator.rs
+++ b/src/orchestrator/orchestrator.rs
@@ -78,7 +78,7 @@ impl Orchestrator {
for (i, jobset) in self.jobsets.into_iter().enumerate() {
let merged_store = MergedStores::new(self.release_store.clone(), self.staging_store.clone());
- let multibar = indicatif::MultiProgress::new();
+ let multibar = Arc::new(indicatif::MultiProgress::new());
let results = { // run the jobs in the set
let unordered_results = futures::stream::FuturesUnordered::new();
@@ -86,7 +86,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).await?;
+ let jobhandle = self.scheduler.schedule_job(runnable, multibar.clone()).await?;
trace!("Jobhandle -> {:?}", jobhandle);
// clone the bar here, so we can give a handle to the async result fetcher closure