admin/n8n-enterprise-unlocked
1
0
Fork 0
mirror of https://github.com/Abdulazizzn/n8n-enterprise-unlocked.git synced 2025-12-17 01:56:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(core): Add workflowId to all job processor logs (#16726)

Browse Source
This commit is contained in:
Danny Martini
2025-06-26 12:31:12 +02:00
committed by GitHub
parent 892b0d2a82
commit 20418c7966
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
packages/cli/src/scaling/job-processor.ts
View File

@@ -72,6 +72,7 @@ export class JobProcessor {
this.logger.info(`Worker started execution ${executionId} (job ${job.id})`, { this.logger.info(`Worker started execution ${executionId} (job ${job.id})`, {
executionId, executionId,
workflowId,
jobId: job.id, 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 // Can't set the status directly in the queued worker, but it will happen in InternalHook.onWorkflowPostExecute
this.logger.debug( this.logger.debug(
`Queued worker execution status for execution ${executionId} (job ${job.id}) is "${status}"`, `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})`, { this.logger.info(`Worker finished execution ${executionId} (job ${job.id})`, {
executionId, executionId,
workflowId,
jobId: job.id, jobId: job.id,
}); });