diff options
Diffstat (limited to 'packages/plugins/queue-restate/src/tests/queue.test.ts')
| -rw-r--r-- | packages/plugins/queue-restate/src/tests/queue.test.ts | 13 |
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]); - }); - }); }); |
