diff options
| author | Mohamed Bassem <me@mbassem.com> | 2025-11-24 01:23:06 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-11-24 01:23:06 +0000 |
| commit | 54268759492df88644e4279fdcc600214f922f43 (patch) | |
| tree | 610cb784662ca2c7513f67aa7a74f3a8d3e40b3f /packages/plugins/queue-restate/src/index.ts | |
| parent | 38842f77e549fd0946e43a40c65abe0f196c3f04 (diff) | |
| download | karakeep-54268759492df88644e4279fdcc600214f922f43.tar.zst | |
feat: Introduce groupId in restate queue (#2168)
* feat: Introduce groupId in restate queue
* add group ids to the interface
* use last served timestamp
Diffstat (limited to 'packages/plugins/queue-restate/src/index.ts')
| -rw-r--r-- | packages/plugins/queue-restate/src/index.ts | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/packages/plugins/queue-restate/src/index.ts b/packages/plugins/queue-restate/src/index.ts index 98668872..de37bbea 100644 --- a/packages/plugins/queue-restate/src/index.ts +++ b/packages/plugins/queue-restate/src/index.ts @@ -41,6 +41,7 @@ class RestateQueueWrapper<T> implements Queue<T> { data: { payload: T; priority: number; + groupId?: string; }, ) => Promise<void>; } @@ -49,6 +50,7 @@ class RestateQueueWrapper<T> implements Queue<T> { { payload, priority: options?.priority ?? 0, + groupId: options?.groupId, }, restateClient.rpc.sendOpts({ delay: options?.delayMs |