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/tests/queue.test.ts | 13 ------------- 1 file changed, 13 deletions(-) (limited to 'packages/plugins/queue-restate/src/tests/queue.test.ts') 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