diff --git a/packages/cli/src/scaling/job-processor.ts b/packages/cli/src/scaling/job-processor.ts index 6940383e18..f5c04b5d29 100644 --- a/packages/cli/src/scaling/job-processor.ts +++ b/packages/cli/src/scaling/job-processor.ts @@ -72,6 +72,7 @@ export class JobProcessor { this.logger.info(`Worker started execution ${executionId} (job ${job.id})`, { executionId, + workflowId, jobId: job.id, }); @@ -168,6 +169,11 @@ export class JobProcessor { // Can't set the status directly in the queued worker, but it will happen in InternalHook.onWorkflowPostExecute this.logger.debug( `Queued worker execution status for execution ${executionId} (job ${job.id}) is "${status}"`, + { + executionId, + workflowId, + jobId: job.id, + }, ); }; @@ -241,6 +247,7 @@ export class JobProcessor { this.logger.info(`Worker finished execution ${executionId} (job ${job.id})`, { executionId, + workflowId, jobId: job.id, });