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 await statement to hooks (#1775)

Browse source
This commit is contained in:
Omar Ajoue 2021-05-12 05:15:22 +02:00 committed by GitHub
parent caa55a022b
commit 6ffc544888
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -194,9 +194,9 @@ export class WorkflowRunnerProcess {
* @param {any[]} parameters * @param {any[]} parameters
* @memberof WorkflowRunnerProcess * @memberof WorkflowRunnerProcess
*/ */
sendHookToParentProcess(hook: string, parameters: any[]) { // tslint:disable-line:no-any async sendHookToParentProcess(hook: string, parameters: any[]) { // tslint:disable-line:no-any
try { try {
sendToParentProcess('processHook', { await sendToParentProcess('processHook', {
hook, hook,
parameters, parameters,
}); });
@ -217,22 +217,22 @@ export class WorkflowRunnerProcess {
const hookFunctions: IWorkflowExecuteHooks = { const hookFunctions: IWorkflowExecuteHooks = {
nodeExecuteBefore: [ nodeExecuteBefore: [
async (nodeName: string): Promise<void> => { async (nodeName: string): Promise<void> => {
this.sendHookToParentProcess('nodeExecuteBefore', [nodeName]); await this.sendHookToParentProcess('nodeExecuteBefore', [nodeName]);
}, },
], ],
nodeExecuteAfter: [ nodeExecuteAfter: [
async (nodeName: string, data: ITaskData): Promise<void> => { async (nodeName: string, data: ITaskData): Promise<void> => {
this.sendHookToParentProcess('nodeExecuteAfter', [nodeName, data]); await this.sendHookToParentProcess('nodeExecuteAfter', [nodeName, data]);
}, },
], ],
workflowExecuteBefore: [ workflowExecuteBefore: [
async (): Promise<void> => { async (): Promise<void> => {
this.sendHookToParentProcess('workflowExecuteBefore', []); await this.sendHookToParentProcess('workflowExecuteBefore', []);
}, },
], ],
workflowExecuteAfter: [ workflowExecuteAfter: [
async (fullRunData: IRun, newStaticData?: IDataObject): Promise<void> => { async (fullRunData: IRun, newStaticData?: IDataObject): Promise<void> => {
this.sendHookToParentProcess('workflowExecuteAfter', [fullRunData, newStaticData]); await this.sendHookToParentProcess('workflowExecuteAfter', [fullRunData, newStaticData]);
}, },
], ],
}; };