From a71b9505ea76596659c98eb6180a09a895399741 Mon Sep 17 00:00:00 2001
From: Mohamed Bassem <me@mbassem.com>
Date: Sun, 30 Nov 2025 00:19:28 +0000
Subject: fix: Add restate queued idempotency (#2169)

* fix: Add restate queued idempotency

* return on failed to acquire
---
 packages/plugins/queue-restate/src/index.ts | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

(limited to 'packages/plugins/queue-restate/src/index.ts')

diff --git a/packages/plugins/queue-restate/src/index.ts b/packages/plugins/queue-restate/src/index.ts
index de37bbea..fa636f87 100644
--- a/packages/plugins/queue-restate/src/index.ts
+++ b/packages/plugins/queue-restate/src/index.ts
@@ -42,6 +42,7 @@ class RestateQueueWrapper<T> implements Queue<T> {
           payload: T;
           priority: number;
           groupId?: string;
+          queuedIdempotencyKey?: string;
         },
       ) => Promise<void>;
     }
@@ -51,6 +52,7 @@ class RestateQueueWrapper<T> implements Queue<T> {
         payload,
         priority: options?.priority ?? 0,
         groupId: options?.groupId,
+        queuedIdempotencyKey: options?.idempotencyKey,
       },
       restateClient.rpc.sendOpts({
         delay: options?.delayMs
@@ -58,7 +60,6 @@ class RestateQueueWrapper<T> implements Queue<T> {
               milliseconds: options.delayMs,
             }
           : undefined,
-        idempotencyKey: options?.idempotencyKey,
       }),
     );
     return res.invocationId;
-- 
cgit v1.2.3-70-g09d2