summaryrefslogtreecommitdiffstats
path: root/src/endpoint/scheduler.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/endpoint/scheduler.rs')
-rw-r--r--src/endpoint/scheduler.rs5
1 files changed, 3 insertions, 2 deletions
diff --git a/src/endpoint/scheduler.rs b/src/endpoint/scheduler.rs
index a4721a8..a993833 100644
--- a/src/endpoint/scheduler.rs
+++ b/src/endpoint/scheduler.rs
@@ -179,9 +179,10 @@ impl JobHandle {
log_dir: self.log_dir.as_ref(),
job_id,
log_receiver,
- bar: &self.bar,
+ bar: self.bar.clone(),
}
.join();
+ drop(self.bar);
let (run_container, logres) = tokio::join!(running_container, logres);
let log = logres.with_context(|| anyhow!("Collecting logs for job on '{}'", ep.name()))?;
@@ -320,7 +321,7 @@ struct LogReceiver<'a> {
log_dir: Option<&'a PathBuf>,
job_id: Uuid,
log_receiver: UnboundedReceiver<LogItem>,
- bar: &'a ProgressBar,
+ bar: ProgressBar,
}
impl<'a> LogReceiver<'a> {