Skip to content

Commit

Permalink
Fixing workers bottleneck
Browse files Browse the repository at this point in the history
  • Loading branch information
omri10 committed Sep 12, 2023
1 parent 005a362 commit 2ae46f4
Showing 1 changed file with 9 additions and 9 deletions.
18 changes: 9 additions & 9 deletions packages/core/src/WorkflowExecute.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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;
}

Expand Down

0 comments on commit 2ae46f4

Please sign in to comment.