diff --git a/packages/cli/src/modules/instance-ai/__tests__/instance-ai.adapter.service.security.test.ts b/packages/cli/src/modules/instance-ai/__tests__/instance-ai.adapter.service.security.test.ts index 3095762baec..fdf88acaba2 100644 --- a/packages/cli/src/modules/instance-ai/__tests__/instance-ai.adapter.service.security.test.ts +++ b/packages/cli/src/modules/instance-ai/__tests__/instance-ai.adapter.service.security.test.ts @@ -386,6 +386,26 @@ describe('stop execution — workflow:execute scope', () => { 'workflow:read', ]); }); + + it('getStatus returns the workflow and version of a running execution', async () => { + executionRepository.findSingleExecution.mockReset().mockResolvedValue({ + id: 'exec-1', + workflowId: 'wf-1', + workflowVersionId: 'version-1', + } as never); + workflowFinderService.findWorkflowForUser.mockResolvedValue({ id: 'wf-1' } as never); + activeExecutions.has.mockReturnValue(true); + + const ctx = service.createContext(user); + const result = await ctx.executionService.getStatus('exec-1'); + + expect(result).toEqual({ + executionId: 'exec-1', + workflowId: 'wf-1', + workflowVersionId: 'version-1', + status: 'running', + }); + }); }); // --------------------------------------------------------------------------- diff --git a/packages/cli/src/modules/instance-ai/instance-ai.adapter.service.ts b/packages/cli/src/modules/instance-ai/instance-ai.adapter.service.ts index 892050a0148..ecdee59c697 100644 --- a/packages/cli/src/modules/instance-ai/instance-ai.adapter.service.ts +++ b/packages/cli/src/modules/instance-ai/instance-ai.adapter.service.ts @@ -2614,10 +2614,15 @@ export class InstanceAiAdapterService { }, async getStatus(executionId: string) { - await assertExecutionAccess(executionId); + const execution = await assertExecutionAccess(executionId); const isRunning = activeExecutions.has(executionId); if (isRunning) { - return { executionId, status: 'running' } satisfies ExecutionResult; + return { + executionId, + workflowId: execution.workflowId, + workflowVersionId: execution.workflowVersionId ?? null, + status: 'running', + } satisfies ExecutionResult; } return await extractExecutionResult(executionId, allowSendingParameterValues, nodeTypes); },