mudhorn/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2024-12-24 20:24:05 -08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

⚡ Add executionId workflow.postExecute external hook (#2569)

Browse source 
Co-authored-by: Jan Oberhauser <janober@users.noreply.github.com>
This commit is contained in:
Vahid Sebto 2021-12-25 16:12:17 +03:30 committed by GitHub
parent 522de66583
commit 8f9dbb7163
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
3 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
packages/cli/src/WorkflowExecuteAdditionalData.ts
View file

@ -918,7 +918,7 @@ export async function executeWorkflow(
}; };
} }
await externalHooks.run('workflow.postExecute', [data, workflowData]); await externalHooks.run('workflow.postExecute', [data, workflowData, executionId]);
void InternalHooksManager.getInstance().onWorkflowPostExecute(executionId, workflowData, data); void InternalHooksManager.getInstance().onWorkflowPostExecute(executionId, workflowData, data);
if (data.finished === true) { if (data.finished === true) {

2
packages/cli/src/WorkflowRunner.ts
View file

@ -186,7 +186,7 @@ export class WorkflowRunner {
if (externalHooks.exists('workflow.postExecute')) { if (externalHooks.exists('workflow.postExecute')) {
postExecutePromise postExecutePromise
.then(async (executionData) => { .then(async (executionData) => {
await externalHooks.run('workflow.postExecute', [executionData, data.workflowData]); await externalHooks.run('workflow.postExecute', [executionData, data.workflowData, executionId]);
}) })
.catch((error) => { .catch((error) => {
console.error('There was a problem running hook "workflow.postExecute"', error); console.error('There was a problem running hook "workflow.postExecute"', error);

2
packages/cli/src/WorkflowRunnerProcess.ts
View file

@ -268,7 +268,7 @@ export class WorkflowRunnerProcess {
this.childExecutions[executionId] = executeWorkflowFunctionOutput; this.childExecutions[executionId] = executeWorkflowFunctionOutput;
const { workflow } = executeWorkflowFunctionOutput; const { workflow } = executeWorkflowFunctionOutput;
result = await workflowExecute.processRunExecutionData(workflow); result = await workflowExecute.processRunExecutionData(workflow);
await externalHooks.run('workflow.postExecute', [result, workflowData]); await externalHooks.run('workflow.postExecute', [result, workflowData, executionId]);
void InternalHooksManager.getInstance().onWorkflowPostExecute( void InternalHooksManager.getInstance().onWorkflowPostExecute(
executionId, executionId,
workflowData, workflowData,