Skip to content

Commit 992b3f4

Browse files
committed
remove retrying after failure status from v4 and fix tests
1 parent eef3626 commit 992b3f4

File tree

2 files changed

+6
-7
lines changed

2 files changed

+6
-7
lines changed

internal-packages/run-engine/src/engine/systems/runAttemptSystem.ts

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -926,7 +926,6 @@ export class RunAttemptSystem {
926926
id: runId,
927927
},
928928
data: {
929-
status: "RETRYING_AFTER_FAILURE",
930929
machinePreset: retryResult.machine,
931930
},
932931
include: {

internal-packages/run-engine/src/engine/tests/attemptFailures.test.ts

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -107,15 +107,15 @@ describe("RunEngine attempt failures", () => {
107107
});
108108
expect(result.attemptStatus).toBe("RETRY_IMMEDIATELY");
109109
expect(result.snapshot.executionStatus).toBe("EXECUTING");
110-
expect(result.run.status).toBe("RETRYING_AFTER_FAILURE");
110+
expect(result.run.status).toBe("EXECUTING");
111111

112112
//state should be pending
113113
const executionData3 = await engine.getRunExecutionData({ runId: run.id });
114114
assertNonNullable(executionData3);
115115
expect(executionData3.snapshot.executionStatus).toBe("EXECUTING");
116116
//only when the new attempt is created, should the attempt be increased
117117
expect(executionData3.run.attemptNumber).toBe(1);
118-
expect(executionData3.run.status).toBe("RETRYING_AFTER_FAILURE");
118+
expect(executionData3.run.status).toBe("EXECUTING");
119119

120120
//create a second attempt
121121
const attemptResult2 = await engine.startRunAttempt({
@@ -600,14 +600,14 @@ describe("RunEngine attempt failures", () => {
600600
// The run should be retried with a larger machine
601601
expect(result.attemptStatus).toBe("RETRY_QUEUED");
602602
expect(result.snapshot.executionStatus).toBe("QUEUED");
603-
expect(result.run.status).toBe("RETRYING_AFTER_FAILURE");
603+
expect(result.run.status).toBe("PENDING");
604604

605605
//state should be pending
606606
const executionData = await engine.getRunExecutionData({ runId: run.id });
607607
assertNonNullable(executionData);
608608
expect(executionData.snapshot.executionStatus).toBe("QUEUED");
609609
expect(executionData.run.attemptNumber).toBe(1);
610-
expect(executionData.run.status).toBe("RETRYING_AFTER_FAILURE");
610+
expect(executionData.run.status).toBe("PENDING");
611611

612612
//create a second attempt
613613
const attemptResult2 = await engine.startRunAttempt({
@@ -761,14 +761,14 @@ describe("RunEngine attempt failures", () => {
761761
// The run should be retried with a larger machine
762762
expect(result.attemptStatus).toBe("RETRY_QUEUED");
763763
expect(result.snapshot.executionStatus).toBe("QUEUED");
764-
expect(result.run.status).toBe("RETRYING_AFTER_FAILURE");
764+
expect(result.run.status).toBe("PENDING");
765765

766766
//state should be queued
767767
const executionData = await engine.getRunExecutionData({ runId: run.id });
768768
assertNonNullable(executionData);
769769
expect(executionData.snapshot.executionStatus).toBe("QUEUED");
770770
expect(executionData.run.attemptNumber).toBe(1);
771-
expect(executionData.run.status).toBe("RETRYING_AFTER_FAILURE");
771+
expect(executionData.run.status).toBe("PENDING");
772772

773773
await engine.runQueue.processMasterQueueForEnvironment(authenticatedEnvironment.id);
774774

0 commit comments

Comments
 (0)