From 54268759492df88644e4279fdcc600214f922f43 Mon Sep 17 00:00:00 2001
From: Mohamed Bassem <me@mbassem.com>
Date: Mon, 24 Nov 2025 01:23:06 +0000
Subject: feat: Introduce groupId in restate queue (#2168)

* feat: Introduce groupId in restate queue

* add group ids to the interface

* use last served timestamp
---
 packages/plugins/queue-restate/src/service.ts | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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

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,
-- 
cgit v1.2.3-70-g09d2