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/service.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/service.ts')
| -rw-r--r-- | packages/plugins/queue-restate/src/service.ts | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/packages/plugins/queue-restate/src/service.ts b/packages/plugins/queue-restate/src/service.ts index 06ed97f5..b26f66cf 100644 --- a/packages/plugins/queue-restate/src/service.ts +++ b/packages/plugins/queue-restate/src/service.ts @@ -40,6 +40,7 @@ export function buildRestateService<T, R>( data: { payload: T; priority: number; + groupId?: string; }, ) => { const id = `${await genId(ctx)}`; @@ -64,7 +65,7 @@ export function buildRestateService<T, R>( let lastError: Error | undefined; for (let runNumber = 0; runNumber <= NUM_RETRIES; runNumber++) { - await semaphore.acquire(priority); + await semaphore.acquire(priority, data.groupId); const res = await runWorkerLogic(ctx, funcs, { id, data: payload, |