diff options
Diffstat (limited to 'src/endpoint/scheduler.rs')
-rw-r--r-- | src/endpoint/scheduler.rs | 5 |
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> { |