aboutsummaryrefslogtreecommitdiffstats
path: root/packages/plugins/queue-restate/src/tests
diff options
context:
space:
mode:
authorMohamed Bassem <me@mbassem.com>2025-12-15 15:48:07 +0000
committerMohamed Bassem <me@mbassem.com>2025-12-15 15:48:07 +0000
commit510174db9661815de3c9b3dd8deb00c9db582054 (patch)
tree98b2a15fdf623097333868687c08b02a3f9754c4 /packages/plugins/queue-restate/src/tests
parent7f4202afd73105b850498b55ad66922b3505f0e3 (diff)
downloadkarakeep-510174db9661815de3c9b3dd8deb00c9db582054.tar.zst
Revert "fix: fix restate service to return control to restate service on timeout"
This reverts commit 6db14ac492cd5d9e26d0d986513771f14faa7fd0.
Diffstat (limited to 'packages/plugins/queue-restate/src/tests')
-rw-r--r--packages/plugins/queue-restate/src/tests/queue.test.ts13
1 files changed, 0 insertions, 13 deletions
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]);
- });
- });
});