aboutsummaryrefslogtreecommitdiffstats
path: root/packages/plugins/queue-restate/src/index.ts
diff options
context:
space:
mode:
authorMohamed Bassem <me@mbassem.com>2025-11-30 00:19:28 +0000
committerGitHub <noreply@github.com>2025-11-30 00:19:28 +0000
commita71b9505ea76596659c98eb6180a09a895399741 (patch)
treeceabe80e36d36f594e92c7b3823147abe6e6b474 /packages/plugins/queue-restate/src/index.ts
parentb12c1c3a82941f2767ade8f497db56933415b94d (diff)
downloadkarakeep-a71b9505ea76596659c98eb6180a09a895399741.tar.zst
fix: Add restate queued idempotency (#2169)
* fix: Add restate queued idempotency * return on failed to acquire
Diffstat (limited to 'packages/plugins/queue-restate/src/index.ts')
-rw-r--r--packages/plugins/queue-restate/src/index.ts3
1 files changed, 2 insertions, 1 deletions
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;