mirror of
https://github.com/n8n-io/n8n.git
synced 2024-11-14 16:44:07 -08:00
fix(core): Make push work for waiting webhooks (#11678)
This commit is contained in:
parent
cbdd535fe0
commit
600479bf36
|
@ -215,7 +215,7 @@ export class WaitingWebhooks implements IWebhookManager {
|
||||||
workflowData as IWorkflowDb,
|
workflowData as IWorkflowDb,
|
||||||
workflowStartNode,
|
workflowStartNode,
|
||||||
executionMode,
|
executionMode,
|
||||||
undefined,
|
runExecutionData.pushRef,
|
||||||
runExecutionData,
|
runExecutionData,
|
||||||
execution.id,
|
execution.id,
|
||||||
req,
|
req,
|
||||||
|
|
|
@ -495,6 +495,11 @@ function hookFunctionsSave(): IWorkflowExecuteHooks {
|
||||||
retryOf: this.retryOf,
|
retryOf: this.retryOf,
|
||||||
});
|
});
|
||||||
|
|
||||||
|
// When going into the waiting state, store the pushRef in the execution-data
|
||||||
|
if (fullRunData.waitTill && isManualMode) {
|
||||||
|
fullExecutionData.data.pushRef = this.pushRef;
|
||||||
|
}
|
||||||
|
|
||||||
await updateExistingExecution({
|
await updateExistingExecution({
|
||||||
executionId: this.executionId,
|
executionId: this.executionId,
|
||||||
workflowId: this.workflowData.id,
|
workflowId: this.workflowData.id,
|
||||||
|
|
|
@ -2114,6 +2114,7 @@ export interface IRunExecutionData {
|
||||||
waitingExecutionSource: IWaitingForExecutionSource | null;
|
waitingExecutionSource: IWaitingForExecutionSource | null;
|
||||||
};
|
};
|
||||||
waitTill?: Date;
|
waitTill?: Date;
|
||||||
|
pushRef?: string;
|
||||||
}
|
}
|
||||||
|
|
||||||
export interface IRunData {
|
export interface IRunData {
|
||||||
|
|
Loading…
Reference in a new issue