diff --git a/packages/twenty-server/src/engine/core-modules/message-queue/drivers/bullmq.driver.ts b/packages/twenty-server/src/engine/core-modules/message-queue/drivers/bullmq.driver.ts index ae9bb55365..0f94e52594 100644 --- a/packages/twenty-server/src/engine/core-modules/message-queue/drivers/bullmq.driver.ts +++ b/packages/twenty-server/src/engine/core-modules/message-queue/drivers/bullmq.driver.ts @@ -111,16 +111,20 @@ export class BullMQDriver async (job) => { // TODO: Correctly support for job.id const timeStart = performance.now(); + const workspaceId = job.data?.workspaceId; + const workspaceSuffix = workspaceId + ? ` [workspace=${workspaceId}]` + : ''; this.logger.log( - `Processing job ${job.id} with name ${job.name} on queue ${queueName}`, + `Processing job ${job.id} with name ${job.name} on queue ${queueName}${workspaceSuffix}`, ); await handler({ data: job.data, id: job.id ?? '', name: job.name }); const timeEnd = performance.now(); const executionTime = timeEnd - timeStart; this.logger.log( - `Job ${job.id} with name ${job.name} processed on queue ${queueName} in ${executionTime.toFixed(2)}ms`, + `Job ${job.id} with name ${job.name} processed on queue ${queueName} in ${executionTime.toFixed(2)}ms${workspaceSuffix}`, ); }, workerOptions, diff --git a/packages/twenty-server/src/modules/workflow/workflow-runner/jobs/run-workflow.job.ts b/packages/twenty-server/src/modules/workflow/workflow-runner/jobs/run-workflow.job.ts index 09f5afd463..4d04fb9cc2 100644 --- a/packages/twenty-server/src/modules/workflow/workflow-runner/jobs/run-workflow.job.ts +++ b/packages/twenty-server/src/modules/workflow/workflow-runner/jobs/run-workflow.job.ts @@ -1,4 +1,4 @@ -import { Scope } from '@nestjs/common'; +import { Logger, Scope } from '@nestjs/common'; import { isDefined } from 'twenty-shared/utils'; @@ -24,6 +24,8 @@ import { WorkflowTriggerType } from 'src/modules/workflow/workflow-trigger/types @Processor({ queueName: MessageQueue.workflowQueue, scope: Scope.REQUEST }) export class RunWorkflowJob { + private readonly logger = new Logger(RunWorkflowJob.name); + constructor( private readonly workflowCommonWorkspaceService: WorkflowCommonWorkspaceService, private readonly codeStepBuildService: CodeStepBuildService, @@ -39,6 +41,9 @@ export class RunWorkflowJob { lastExecutedStepId, workspaceId, }: RunWorkflowJobData): Promise { + this.logger.log( + `Running workflow run ${workflowRunId} in workspace ${workspaceId}`, + ); const authContext = buildSystemAuthContext(workspaceId); await this.globalWorkspaceOrmManager.executeInWorkspaceContext(async () => {