aboutsummaryrefslogtreecommitdiffstats
path: root/packages
diff options
context:
space:
mode:
authorMohamed Bassem <me@mbassem.com>2026-01-03 13:27:59 +0000
committerMohamed Bassem <me@mbassem.com>2026-01-03 13:27:59 +0000
commit4c0220f21714add712c70fbc3414c26ca57cd8f3 (patch)
tree2c2ebf17501776d3f701438edea3bef8f8e40517 /packages
parent6fe20639702e3eb81bd262075094fb5d1f7033b9 (diff)
downloadkarakeep-4c0220f21714add712c70fbc3414c26ca57cd8f3.tar.zst
fix: drop idProvider from restate hot path
Diffstat (limited to 'packages')
-rw-r--r--packages/plugins/queue-restate/src/service.ts3
1 files changed, 1 insertions, 2 deletions
diff --git a/packages/plugins/queue-restate/src/service.ts b/packages/plugins/queue-restate/src/service.ts
index d466753e..f27fd200 100644
--- a/packages/plugins/queue-restate/src/service.ts
+++ b/packages/plugins/queue-restate/src/service.ts
@@ -9,7 +9,6 @@ import type {
import { QueueRetryAfterError } from "@karakeep/shared/queueing";
import { tryCatch } from "@karakeep/shared/tryCatch";
-import { genId } from "./idProvider";
import { RestateSemaphore } from "./semaphore";
export function buildRestateService<T, R>(
@@ -48,7 +47,7 @@ export function buildRestateService<T, R>(
groupId?: string;
},
) => {
- const id = `${await genId(ctx)}`;
+ const id = ctx.rand.uuidv4();
let payload = data.payload;
if (opts.validator) {
const res = opts.validator.safeParse(data.payload);