diff options
| author | Mohamed Bassem <me@mbassem.com> | 2026-01-03 13:27:59 +0000 |
|---|---|---|
| committer | Mohamed Bassem <me@mbassem.com> | 2026-01-03 13:27:59 +0000 |
| commit | 4c0220f21714add712c70fbc3414c26ca57cd8f3 (patch) | |
| tree | 2c2ebf17501776d3f701438edea3bef8f8e40517 /packages | |
| parent | 6fe20639702e3eb81bd262075094fb5d1f7033b9 (diff) | |
| download | karakeep-4c0220f21714add712c70fbc3414c26ca57cd8f3.tar.zst | |
fix: drop idProvider from restate hot path
Diffstat (limited to 'packages')
| -rw-r--r-- | packages/plugins/queue-restate/src/service.ts | 3 |
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); |
