From d4b7b89ae201dddb8411add4bb6b99a60884fce1 Mon Sep 17 00:00:00 2001
From: Mohamed Bassem <me@mbassem.com>
Date: Mon, 10 Nov 2025 09:54:42 +0000
Subject: fix: stop retrying indefinitely in restate queues

---
 packages/plugins/queue-restate/src/service.ts | 9 +++++++++
 1 file changed, 9 insertions(+)

(limited to 'packages/plugins')

diff --git a/packages/plugins/queue-restate/src/service.ts b/packages/plugins/queue-restate/src/service.ts
index d19cad4c..8618b8ab 100644
--- a/packages/plugins/queue-restate/src/service.ts
+++ b/packages/plugins/queue-restate/src/service.ts
@@ -24,6 +24,15 @@ export function buildRestateService<T, R>(
       inactivityTimeout: {
         seconds: opts.timeoutSecs,
       },
+      retryPolicy: {
+        maxAttempts: NUM_RETRIES,
+        initialInterval: {
+          seconds: 5,
+        },
+        maxInterval: {
+          minutes: 1,
+        },
+      },
     },
     handlers: {
       run: async (
-- 
cgit v1.2.3-70-g09d2