From bc100f25056564070ebe8d32bc5edc7fd8ac3c05 Mon Sep 17 00:00:00 2001 From: Utku <74243531+utkubakir@users.noreply.github.com> Date: Tue, 27 Jun 2023 22:26:59 +0300 Subject: [PATCH] Fix job resuming/pausing and cancelling (#1035) why this works? --- core/src/job/manager.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/job/manager.rs b/core/src/job/manager.rs index 8e346573e..50f770925 100644 --- a/core/src/job/manager.rs +++ b/core/src/job/manager.rs @@ -119,7 +119,7 @@ impl JobManager { if running_workers.len() < MAX_WORKERS { info!("Running job: {:?}", job.name()); - let worker_id = job_report.id; + let worker_id = job_report.parent_id.unwrap_or(job_report.id); Worker::new(worker_id, job, job_report, library.clone(), self.clone()) .await