admin/n8n-enterprise-unlocked
1
0
Fork 0
mirror of https://github.com/Abdulazizzn/n8n-enterprise-unlocked.git synced 2025-12-16 09:36:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: PAY-2613 add missing status field for select (#19071)

Browse Source 
Co-authored-by: Stephen Wright <stephen.wright@Mac.Home>
This commit is contained in:
Stephen Wright
2025-09-02 13:34:27 +01:00
committed by GitHub
parent 1ced801358
commit 9569965a0b
3 changed files with 14 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
packages/@n8n/db/src/repositories/execution.repository.ts
View File

@@ -706,6 +706,7 @@ export class ExecutionRepository extends Repository<ExecutionEntity> {
'workflowId',
'waitTill',
'finished',
'status',
],
where,
order: { id: 'DESC' },

3
packages/cli/src/public-api/v1/handlers/executions/spec/schemas/execution.yml
View File

@@ -33,3 +33,6 @@ properties:
format: date-time
customData:
type: object
status:
type: string
enum: ['canceled', 'crashed', 'error', 'new', 'running', 'success', 'unknown', 'waiting']

10
packages/cli/test/integration/public-api/executions.test.ts
View File

@@ -263,6 +263,7 @@ describe('GET /executions', () => {
stoppedAt,
workflowId,
waitTill,
status,
} = response.body.data[0];
expect(id).toBeDefined();
@@ -274,6 +275,7 @@ describe('GET /executions', () => {
expect(stoppedAt).not.toBeNull();
expect(workflowId).toBe(successfulExecution.workflowId);
expect(waitTill).toBeNull();
expect(status).toBe(successfulExecution.status);
});
test('should paginate two executions', async () => {
@@ -317,6 +319,7 @@ describe('GET /executions', () => {
stoppedAt,
workflowId,
waitTill,
status,
} = executions[i];
expect(id).toBeDefined();
@@ -328,6 +331,7 @@ describe('GET /executions', () => {
expect(stoppedAt).not.toBeNull();
expect(workflowId).toBe(successfulExecutions[i].workflowId);
expect(waitTill).toBeNull();
expect(status).toBe(successfulExecutions[i].status);
}
});
@@ -356,6 +360,7 @@ describe('GET /executions', () => {
stoppedAt,
workflowId,
waitTill,
status,
} = response.body.data[0];
expect(id).toBeDefined();
@@ -367,6 +372,7 @@ describe('GET /executions', () => {
expect(stoppedAt).not.toBeNull();
expect(workflowId).toBe(errorExecution.workflowId);
expect(waitTill).toBeNull();
expect(status).toBe(errorExecution.status);
});
test('should return all waiting executions', async () => {
@@ -396,6 +402,7 @@ describe('GET /executions', () => {
stoppedAt,
workflowId,
waitTill,
status,
} = response.body.data[0];
expect(id).toBeDefined();
@@ -407,6 +414,7 @@ describe('GET /executions', () => {
expect(stoppedAt).not.toBeNull();
expect(workflowId).toBe(waitingExecution.workflowId);
expect(new Date(waitTill).getTime()).toBeGreaterThan(Date.now() - 1000);
expect(status).toBe(waitingExecution.status);
});
test('should retrieve all executions of specific workflow', async () => {
@@ -434,6 +442,7 @@ describe('GET /executions', () => {
stoppedAt,
workflowId,
waitTill,
status,
} = execution;
expect(savedExecutions.some((exec) => exec.id === id)).toBe(true);
@@ -445,6 +454,7 @@ describe('GET /executions', () => {
expect(stoppedAt).not.toBeNull();
expect(workflowId).toBe(workflow.id);
expect(waitTill).toBeNull();
expect(status).toBe(execution.status);
}
});