From 2ae46f45fde74a45b387a1d46eecd30bb915b39f Mon Sep 17 00:00:00 2001 From: Omri Attoun Date: Tue, 12 Sep 2023 14:01:41 -0700 Subject: [PATCH] Fixing workers bottleneck --- packages/core/src/WorkflowExecute.ts | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/packages/core/src/WorkflowExecute.ts b/packages/core/src/WorkflowExecute.ts index e57ff1311956e..c47208dcc53e5 100644 --- a/packages/core/src/WorkflowExecute.ts +++ b/packages/core/src/WorkflowExecute.ts @@ -1348,15 +1348,15 @@ export class WorkflowExecute { } } - const executionId: string = - this.additionalData.executionId ?? 'unknown_execution' + Date.now().toString(); - await this.storeFullDataInElasticSearch(executionId, workflow.id || '', fullRunData); // Store in Elastic - await this.storeFullDataInS3( - workflow.id, - executionId, - fullRunData.data.resultData.error, - fullRunData, - ); + // const executionId: string = + // this.additionalData.executionId ?? 'unknown_execution' + Date.now().toString(); + // // await this.storeFullDataInElasticSearch(executionId, workflow.id || '', fullRunData); // Store in Elastic + // // await this.storeFullDataInS3( + // // workflow.id, + // // executionId, + // // fullRunData.data.resultData.error, + // // fullRunData, + // // ); return fullRunData; }