mudhorn/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2024-11-14 08:34:07 -08:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

add a new execution status type executionWaiting

Browse source
This commit is contained in:
कारतोफ्फेलस्क्रिप्ट™ 2024-11-12 11:52:40 +01:00
parent 314504c456
commit 27578ccdcc
No known key found for this signature in database
3 changed files with 16 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
packages/@n8n/api-types/src/push/execution.ts
View file

@ -12,6 +12,15 @@ type ExecutionStarted = {
};
};
type ExecutionWaiting = {
type: 'executionWaiting';
data: {
executionId: string;
data: IRun;
retryOf?: string;
};
};
type ExecutionFinished = {
type: 'executionFinished';
data: {
@ -47,6 +56,7 @@ type NodeExecuteAfter = {
export type ExecutionPushMessage =
| ExecutionStarted
| ExecutionWaiting
| ExecutionFinished
| ExecutionRecovered
| NodeExecuteBefore

6
packages/cli/src/workflow-execute-additional-data.ts
View file

@ -347,9 +347,11 @@ function hookFunctionsPush(): IWorkflowExecuteHooks {
executionId,
workflowId,
});
// TODO: Look at this again
const pushType =
fullRunData.status === 'waiting' ? 'executionWaiting' : 'executionFinished';
pushInstance.send(
'executionFinished',
pushType,
{
executionId,
data: pushRunData,

2
packages/editor-ui/src/composables/usePushConnection.ts
View file

@ -499,6 +499,8 @@ export function usePushConnection({ router }: { router: ReturnType<typeof useRou
runDataExecutedStartData: runDataExecuted.data.startData,
resultDataError: runDataExecuted.data.resultData.error,
});
} else if (receivedData.type === 'executionWaiting') {
// TODO: Do something here
} else if (receivedData.type === 'executionStarted') {
const pushData = receivedData.data;