[PR #2370] [MERGED] fix: harden the restate implementation #2086

New issue

Closed

opened 2026-03-02 12:00:30 +03:00 by kerem · 0 comments

kerem commented

2026-03-02 12:00:30 +03:00

Owner

📋 Pull Request Information

Original PR: https://github.com/karakeep-app/karakeep/pull/2370
Author: @MohamedBassem
Created: 1/10/2026
Status: ✅ Merged
Merged: 1/10/2026
Merged by: @MohamedBassem

Base: main ← Head: fix/restate-harderning

📝 Commits (10+)

04607a4 fix: parallelize queue enqueues in bookmark routes
f0691d1 fix: guard meilisearch client init with mutex
91a300e fix: fix propagation of last error in restate
16ac88e fix: don't fail invocations when the job fails
63f61c2 fix: add a timeout around the worker runner logic
b98eb0e fix: add leases to handle dangling semaphores
08c9f54 feat: separate dispatchers and runners
c791105 Merge branch 'main' into fix/restate-harderning
2ce19ad add a test
8057121 fix silent promise failure

📊 Changes

8 files changed (+611 additions, -211 deletions)

View changed files

➕ packages/plugins/queue-restate/src/dispatcher.ts (+189 -0)
📝 packages/plugins/queue-restate/src/env.ts (+3 -0)
📝 packages/plugins/queue-restate/src/index.ts (+28 -11)
➕ packages/plugins/queue-restate/src/runner.ts (+164 -0)
📝 packages/plugins/queue-restate/src/semaphore.ts (+48 -23)
📝 packages/plugins/queue-restate/src/service.ts (+13 -177)
📝 packages/plugins/queue-restate/src/tests/queue.test.ts (+88 -0)
➕ packages/plugins/queue-restate/src/types.ts (+78 -0)

📄 Description

No description provided

_{🔄 This issue represents a GitHub Pull Request. It cannot be merged through Gitea due to API limitations.}

## 📋 Pull Request Information **Original PR:** https://github.com/karakeep-app/karakeep/pull/2370 **Author:** [@MohamedBassem](https://github.com/MohamedBassem) **Created:** 1/10/2026 **Status:** ✅ Merged **Merged:** 1/10/2026 **Merged by:** [@MohamedBassem](https://github.com/MohamedBassem) **Base:** `main` ← **Head:** `fix/restate-harderning` --- ### 📝 Commits (10+) - [`04607a4`](https://github.com/karakeep-app/karakeep/commit/04607a4249c4374b4258dc8e7440c4c004bb8a01) fix: parallelize queue enqueues in bookmark routes - [`f0691d1`](https://github.com/karakeep-app/karakeep/commit/f0691d17445cfe60b7ea5638088c3e0082548a9a) fix: guard meilisearch client init with mutex - [`91a300e`](https://github.com/karakeep-app/karakeep/commit/91a300e457488108621148a5ec30590520d7067c) fix: fix propagation of last error in restate - [`16ac88e`](https://github.com/karakeep-app/karakeep/commit/16ac88e7ca4be72779c05d9f9eb0e98af07fad61) fix: don't fail invocations when the job fails - [`63f61c2`](https://github.com/karakeep-app/karakeep/commit/63f61c265b3c434c36492019b185badec5564ebc) fix: add a timeout around the worker runner logic - [`b98eb0e`](https://github.com/karakeep-app/karakeep/commit/b98eb0ebc6c692da9554f2e8bf1f7d035dd89584) fix: add leases to handle dangling semaphores - [`08c9f54`](https://github.com/karakeep-app/karakeep/commit/08c9f54ef744d4936b771d3769e1622a2c1153cc) feat: separate dispatchers and runners - [`c791105`](https://github.com/karakeep-app/karakeep/commit/c791105caa2b7c640268306b41ac7e16fa520b25) Merge branch 'main' into fix/restate-harderning - [`2ce19ad`](https://github.com/karakeep-app/karakeep/commit/2ce19ad117e1f24b46c1f39b903846b70ef246ee) add a test - [`8057121`](https://github.com/karakeep-app/karakeep/commit/80571212e0ad08de56168599223ff4208a47f194) fix silent promise failure ### 📊 Changes **8 files changed** (+611 additions, -211 deletions) <details> <summary>View changed files</summary> ➕ `packages/plugins/queue-restate/src/dispatcher.ts` (+189 -0) 📝 `packages/plugins/queue-restate/src/env.ts` (+3 -0) 📝 `packages/plugins/queue-restate/src/index.ts` (+28 -11) ➕ `packages/plugins/queue-restate/src/runner.ts` (+164 -0) 📝 `packages/plugins/queue-restate/src/semaphore.ts` (+48 -23) 📝 `packages/plugins/queue-restate/src/service.ts` (+13 -177) 📝 `packages/plugins/queue-restate/src/tests/queue.test.ts` (+88 -0) ➕ `packages/plugins/queue-restate/src/types.ts` (+78 -0) </details> ### 📄 Description _No description provided_ --- <sub>🔄 This issue represents a GitHub Pull Request. It cannot be merged through Gitea due to API limitations.</sub>

kerem

2026-03-02 12:00:30 +03:00

closed this issue
added the
pull-request
label

No milestone

No project

No assignees

1 participant

Notifications

Due date

The due date is invalid or out of range. Please use the format "yyyy-mm-dd".

No due date set.

Dependencies

No dependencies set.

Reference

starred/karakeep#2086

No description provided.

Rows
Columns