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