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