Skip to content

Commit 9664de1

Browse files
committed
Fixed cancelling test since bug fix
The old behaviour was wrong for pending executing in the test
1 parent 86ba734 commit 9664de1

File tree

1 file changed

+1
-8
lines changed

1 file changed

+1
-8
lines changed

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

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -150,7 +150,7 @@ describe("RunEngine cancelling", () => {
150150
cancelledEventData.push(result);
151151
});
152152

153-
//todo call completeAttempt (this will happen from the worker)
153+
// call completeAttempt manually (this will happen from the worker)
154154
const completeResult = await engine.completeRunAttempt({
155155
runId: parentRun.id,
156156
snapshotId: executionData!.snapshot.id,
@@ -289,13 +289,6 @@ describe("RunEngine cancelling", () => {
289289
prisma
290290
);
291291

292-
//dequeue the run
293-
await setTimeout(500);
294-
const dequeued = await engine.dequeueFromWorkerQueue({
295-
consumerId: "test_12345",
296-
workerQueue: "main",
297-
});
298-
299292
let cancelledEventData: EventBusEventArgs<"runCancelled">[0][] = [];
300293
engine.eventBus.on("runCancelled", (result) => {
301294
cancelledEventData.push(result);

0 commit comments

Comments
 (0)