From 510174db9661815de3c9b3dd8deb00c9db582054 Mon Sep 17 00:00:00 2001 From: Mohamed Bassem Date: Mon, 15 Dec 2025 15:48:07 +0000 Subject: Revert "fix: fix restate service to return control to restate service on timeout" This reverts commit 6db14ac492cd5d9e26d0d986513771f14faa7fd0. --- packages/plugins/queue-restate/src/service.ts | 9 +-------- packages/plugins/queue-restate/src/tests/queue.test.ts | 13 ------------- 2 files changed, 1 insertion(+), 21 deletions(-) (limited to 'packages') diff --git a/packages/plugins/queue-restate/src/service.ts b/packages/plugins/queue-restate/src/service.ts index fb7e08c2..5ba7d1df 100644 --- a/packages/plugins/queue-restate/src/service.ts +++ b/packages/plugins/queue-restate/src/service.ts @@ -121,14 +121,7 @@ async function runWorkerLogic( ctx.run( `main logic`, async () => { - return await Promise.race([ - run(data), - new Promise((_, reject) => { - data.abortSignal.addEventListener("abort", () => { - reject(new Error(`Job didn't complete within timeout`)); - }); - }), - ]); + return await run(data); }, { maxRetryAttempts: 1, diff --git a/packages/plugins/queue-restate/src/tests/queue.test.ts b/packages/plugins/queue-restate/src/tests/queue.test.ts index 763671d5..2085d57b 100644 --- a/packages/plugins/queue-restate/src/tests/queue.test.ts +++ b/packages/plugins/queue-restate/src/tests/queue.test.ts @@ -517,17 +517,4 @@ describe("Restate Queue Provider", () => { expect(testState.results).toEqual([102, 101, 100]); }, 60000); }); - - describe("inactivity timeout", () => { - it("should timeout jobs that don't complete", async () => { - await queue.enqueue({ type: "stall", durSec: 6 }); - await queue.enqueue({ type: "stall", durSec: 6 }); - await queue.enqueue({ type: "stall", durSec: 6 }); - await queue.enqueue({ type: "val", val: 1 }); - - await waitUntilQueueEmpty(); - - expect(testState.results).toEqual([1]); - }); - }); }); -- cgit v1.2.3-70-g09d2