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 8abe5b83e4c..0b4dd3c6708 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 @@ -72,12 +72,17 @@ export class BullMQDriver implements MessageQueueDriver, OnModuleDestroy { queueName, async (job) => { // TODO: Correctly support for job.id + const timeStart = performance.now(); + this.logger.log( `Processing job ${job.id} with name ${job.name} on queue ${queueName}`, ); 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}`, + `Job ${job.id} with name ${job.name} processed on queue ${queueName} in ${executionTime.toFixed(2)}ms`, ); }, workerOptions, diff --git a/packages/twenty-server/src/engine/core-modules/webhook/jobs/call-webhook-jobs.job.ts b/packages/twenty-server/src/engine/core-modules/webhook/jobs/call-webhook-jobs.job.ts index 2e33a8b92b2..9b4250fc465 100644 --- a/packages/twenty-server/src/engine/core-modules/webhook/jobs/call-webhook-jobs.job.ts +++ b/packages/twenty-server/src/engine/core-modules/webhook/jobs/call-webhook-jobs.job.ts @@ -35,12 +35,6 @@ export class CallWebhookJobsJob { // Also change the openApi schema for webhooks // packages/twenty-server/src/engine/core-modules/open-api/utils/computeWebhooks.utils.ts - this.logger.log( - 'workspaceEventBatch', - workspaceEventBatch.name, - workspaceEventBatch.workspaceId, - workspaceEventBatch.events.length, - ); const [nameSingular, operation] = workspaceEventBatch.name.split('.'); const webhooks = await this.webhookService.findByOperations(