Skip to content

Commit 96680f0

Browse files
committed
fixed run engine delay tests
1 parent 57f45f1 commit 96680f0

File tree

1 file changed

+10
-10
lines changed

1 file changed

+10
-10
lines changed

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

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -73,10 +73,10 @@ describe("RunEngine delays", () => {
7373
prisma
7474
);
7575

76-
//should be created but not queued yet
76+
//should be delayed but not queued yet
7777
const executionData = await engine.getRunExecutionData({ runId: run.id });
7878
assertNonNullable(executionData);
79-
expect(executionData.snapshot.executionStatus).toBe("RUN_CREATED");
79+
expect(executionData.snapshot.executionStatus).toBe("DELAYED");
8080

8181
//wait for 1 seconds
8282
await setTimeout(1_000);
@@ -155,10 +155,10 @@ describe("RunEngine delays", () => {
155155
prisma
156156
);
157157

158-
//should be created but not queued yet
158+
//should be delayed but not queued yet
159159
const executionData = await engine.getRunExecutionData({ runId: run.id });
160160
assertNonNullable(executionData);
161-
expect(executionData.snapshot.executionStatus).toBe("RUN_CREATED");
161+
expect(executionData.snapshot.executionStatus).toBe("DELAYED");
162162

163163
const rescheduleTo = new Date(Date.now() + 1_500);
164164
const updatedRun = await engine.rescheduleDelayedRun({
@@ -170,10 +170,10 @@ describe("RunEngine delays", () => {
170170
//wait so the initial delay passes
171171
await setTimeout(1_000);
172172

173-
//should still be created
173+
//should still be delayed (rescheduled)
174174
const executionData2 = await engine.getRunExecutionData({ runId: run.id });
175175
assertNonNullable(executionData2);
176-
expect(executionData2.snapshot.executionStatus).toBe("RUN_CREATED");
176+
expect(executionData2.snapshot.executionStatus).toBe("DELAYED");
177177

178178
//wait so the updated delay passes
179179
await setTimeout(1_750);
@@ -253,10 +253,10 @@ describe("RunEngine delays", () => {
253253
prisma
254254
);
255255

256-
//should be created but not queued yet
256+
//should be delayed but not queued yet
257257
const executionData = await engine.getRunExecutionData({ runId: run.id });
258258
assertNonNullable(executionData);
259-
expect(executionData.snapshot.executionStatus).toBe("RUN_CREATED");
259+
expect(executionData.snapshot.executionStatus).toBe("DELAYED");
260260
expect(run.status).toBe("DELAYED");
261261

262262
//wait for 1 seconds
@@ -356,10 +356,10 @@ describe("RunEngine delays", () => {
356356
prisma
357357
);
358358

359-
//verify it's created but not queued
359+
//verify it's delayed but not queued
360360
const executionData = await engine.getRunExecutionData({ runId: run.id });
361361
assertNonNullable(executionData);
362-
expect(executionData.snapshot.executionStatus).toBe("RUN_CREATED");
362+
expect(executionData.snapshot.executionStatus).toBe("DELAYED");
363363
expect(run.status).toBe("DELAYED");
364364

365365
//cancel the run

0 commit comments

Comments
 (0)