diff options
| author | Mohamed Bassem <me@mbassem.com> | 2026-01-10 15:31:30 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2026-01-10 15:31:30 +0000 |
| commit | f48e98e16ae588ee5004531bf9a5aed757ed3786 (patch) | |
| tree | fc3b9ca6f0512fef90124e45cbe59dd4c305d5e7 /packages/plugins/queue-restate/src/env.ts | |
| parent | aace8864d7eab5c858a92064b0ac59c122377830 (diff) | |
| download | karakeep-f48e98e16ae588ee5004531bf9a5aed757ed3786.tar.zst | |
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
Diffstat (limited to 'packages/plugins/queue-restate/src/env.ts')
| -rw-r--r-- | packages/plugins/queue-restate/src/env.ts | 3 |
1 files changed, 3 insertions, 0 deletions
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); |