From f48e98e16ae588ee5004531bf9a5aed757ed3786 Mon Sep 17 00:00:00 2001 From: Mohamed Bassem Date: Sat, 10 Jan 2026 15:31:30 +0000 Subject: fix: harden the restate implementation (#2370) * fix: parallelize queue enqueues in bookmark routes * fix: guard meilisearch client init with mutex * fix: fix propagation of last error in restate * fix: don't fail invocations when the job fails * fix: add a timeout around the worker runner logic * fix: add leases to handle dangling semaphores * feat: separate dispatchers and runners * add a test * fix silent promise failure --- packages/plugins/queue-restate/src/env.ts | 3 +++ 1 file changed, 3 insertions(+) (limited to 'packages/plugins/queue-restate/src/env.ts') diff --git a/packages/plugins/queue-restate/src/env.ts b/packages/plugins/queue-restate/src/env.ts index abcfbe51..41003460 100644 --- a/packages/plugins/queue-restate/src/env.ts +++ b/packages/plugins/queue-restate/src/env.ts @@ -17,5 +17,8 @@ export const envConfig = z RESTATE_ADMIN_ADDR: z.string().optional().default("http://localhost:9070"), RESTATE_PUB_KEY: z.string().optional(), RESTATE_EXPOSE_CORE_SERVICES: stringBool("true"), + // Deployment mode configuration - allows running dispatchers and runners separately + RESTATE_ENABLE_DISPATCHERS: stringBool("true"), + RESTATE_ENABLE_RUNNERS: stringBool("true"), }) .parse(process.env); -- cgit v1.2.3-70-g09d2