fix: fix restate service to return control to restate service on timeout

1 files changed, 13 insertions, 0 deletions

diff --git a/packages/plugins/queue-restate/src/tests/queue.test.ts b/packages/plugins/queue-restate/src/tests/queue.test.ts
index 2085d57b..763671d5 100644
--- a/packages/plugins/queue-restate/src/tests/queue.test.ts
+++ b/packages/plugins/queue-restate/src/tests/queue.test.ts
@@ -517,4 +517,17 @@ 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]);
+    });
+  });
 });