diff --git a/packages/cli/src/__tests__/workflow-runner.test.ts b/packages/cli/src/__tests__/workflow-runner.test.ts index 4d590935660..4161eeb5edd 100644 --- a/packages/cli/src/__tests__/workflow-runner.test.ts +++ b/packages/cli/src/__tests__/workflow-runner.test.ts @@ -746,6 +746,35 @@ describe('processError', () => { }); describe('run', () => { + it('reloads static data for a new queued execution', async () => { + globalConfig.executions.mode = 'queue'; + try { + vi.spyOn(runner, 'establishContextForPersistence').mockResolvedValue(undefined); + vi.spyOn(runner, 'prepareNewExecution').mockResolvedValue(mock()); + vi.spyOn(Container.get(CredentialsPermissionChecker), 'check').mockResolvedValueOnce(); + vi.spyOn(Container.get(ActiveExecutions), 'add').mockResolvedValue('1'); + const enqueueExecution = vi.spyOn(runner, 'enqueueExecution').mockResolvedValue(); + + const data = mock({ + executionMode: 'trigger', + workflowData: { id: 'workflow-id', nodes: [], staticData: {} }, + }); + + await runner.run(data, true); + + expect(enqueueExecution).toHaveBeenCalledWith( + '1', + 'workflow-id', + data, + true, + undefined, + undefined, + ); + } finally { + globalConfig.executions.mode = 'regular'; + } + }); + it('uses recreateNodeExecutionStack to create a partial execution if a triggerToStartFrom with data is sent', async () => { // ARRANGE const activeExecutions = Container.get(ActiveExecutions); diff --git a/packages/cli/src/workflow-runner.ts b/packages/cli/src/workflow-runner.ts index 709009dcd85..181913af652 100644 --- a/packages/cli/src/workflow-runner.ts +++ b/packages/cli/src/workflow-runner.ts @@ -469,7 +469,7 @@ export class WorkflowRunner { executionId, workflowId, data, - shouldReloadStaticData, + loadStaticData, realtime, existingExecution?.executionId, );