[PR #2011] [MERGED] feat: Restate-based queue plugin #1947

New issue

Closed

opened 2026-03-02 11:59:53 +03:00 by kerem · 0 comments

kerem commented

2026-03-02 11:59:53 +03:00

Owner

📋 Pull Request Information

Original PR: https://github.com/karakeep-app/karakeep/pull/2011
Author: @MohamedBassem
Created: 10/4/2025
Status: ✅ Merged
Merged: 10/5/2025
Merged by: @MohamedBassem

Base: main ← Head: restate

📝 Commits (10+)

f496ff1 WIP: Initial restate integration
bc1120b add retry
4e2d70c add delay + idempotency
4c5d568 implement concurrency limits
a6885f8 add admin stats
e018a26 add todos
d1ad8d7 add id provider
49203c8 handle onComplete failures
4fb30b9 add tests
fc7468d add pub key and fix logging

📊 Changes

24 files changed (+1049 additions, -13 deletions)

View changed files

📝 apps/workers/index.ts (+8 -2)
📝 packages/plugins-queue-liteque/package.json (+2 -3)
📝 packages/plugins-queue-liteque/src/index.ts (+7 -2)
➕ packages/plugins-queue-restate/.oxlintrc.json (+19 -0)
➕ packages/plugins-queue-restate/index.ts (+12 -0)
➕ packages/plugins-queue-restate/package.json (+27 -0)
➕ packages/plugins-queue-restate/src/admin.ts (+75 -0)
➕ packages/plugins-queue-restate/src/env.ts (+13 -0)
➕ packages/plugins-queue-restate/src/idProvider.ts (+18 -0)
➕ packages/plugins-queue-restate/src/index.ts (+201 -0)
➕ packages/plugins-queue-restate/src/semaphore.ts (+105 -0)
➕ packages/plugins-queue-restate/src/service.ts (+133 -0)
➕ packages/plugins-queue-restate/src/tests/docker-compose.yml (+8 -0)
➕ packages/plugins-queue-restate/src/tests/queue.test.ts (+221 -0)
➕ packages/plugins-queue-restate/src/tests/setup/startContainers.ts (+90 -0)
➕ packages/plugins-queue-restate/src/tests/utils.ts (+23 -0)
➕ packages/plugins-queue-restate/tsconfig.json (+10 -0)
➕ packages/plugins-queue-restate/vitest.config.ts (+14 -0)
📝 packages/plugins-search-meilisearch/package.json (+2 -2)
📝 packages/shared-server/package.json (+1 -0)

...and 4 more files

📄 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/2011 **Author:** [@MohamedBassem](https://github.com/MohamedBassem) **Created:** 10/4/2025 **Status:** ✅ Merged **Merged:** 10/5/2025 **Merged by:** [@MohamedBassem](https://github.com/MohamedBassem) **Base:** `main` ← **Head:** `restate` --- ### 📝 Commits (10+) - [`f496ff1`](https://github.com/karakeep-app/karakeep/commit/f496ff1e53dc2918f5ab8492b94a91a713eab82b) WIP: Initial restate integration - [`bc1120b`](https://github.com/karakeep-app/karakeep/commit/bc1120b5379d4ed33077be7ee934660032a2597f) add retry - [`4e2d70c`](https://github.com/karakeep-app/karakeep/commit/4e2d70c38efee53d24d7bb8dadbe136d7d3789b2) add delay + idempotency - [`4c5d568`](https://github.com/karakeep-app/karakeep/commit/4c5d568eaaef94e9127768fb0ff801af7c805355) implement concurrency limits - [`a6885f8`](https://github.com/karakeep-app/karakeep/commit/a6885f89fe56419fc31d9e94d88d20a214be5668) add admin stats - [`e018a26`](https://github.com/karakeep-app/karakeep/commit/e018a26aa0fecfa82d0a00ada563cc69b98aa86c) add todos - [`d1ad8d7`](https://github.com/karakeep-app/karakeep/commit/d1ad8d7d05296120de3bd1f1d5d73cd334d940d2) add id provider - [`49203c8`](https://github.com/karakeep-app/karakeep/commit/49203c810179b43e82feeff96a9de91d7521e274) handle onComplete failures - [`4fb30b9`](https://github.com/karakeep-app/karakeep/commit/4fb30b94d86f223328393efdb1e2fd13483803b9) add tests - [`fc7468d`](https://github.com/karakeep-app/karakeep/commit/fc7468d7f5d2b8ec791bd62afb70e4b0df4b00ec) add pub key and fix logging ### 📊 Changes **24 files changed** (+1049 additions, -13 deletions) <details> <summary>View changed files</summary> 📝 `apps/workers/index.ts` (+8 -2) 📝 `packages/plugins-queue-liteque/package.json` (+2 -3) 📝 `packages/plugins-queue-liteque/src/index.ts` (+7 -2) ➕ `packages/plugins-queue-restate/.oxlintrc.json` (+19 -0) ➕ `packages/plugins-queue-restate/index.ts` (+12 -0) ➕ `packages/plugins-queue-restate/package.json` (+27 -0) ➕ `packages/plugins-queue-restate/src/admin.ts` (+75 -0) ➕ `packages/plugins-queue-restate/src/env.ts` (+13 -0) ➕ `packages/plugins-queue-restate/src/idProvider.ts` (+18 -0) ➕ `packages/plugins-queue-restate/src/index.ts` (+201 -0) ➕ `packages/plugins-queue-restate/src/semaphore.ts` (+105 -0) ➕ `packages/plugins-queue-restate/src/service.ts` (+133 -0) ➕ `packages/plugins-queue-restate/src/tests/docker-compose.yml` (+8 -0) ➕ `packages/plugins-queue-restate/src/tests/queue.test.ts` (+221 -0) ➕ `packages/plugins-queue-restate/src/tests/setup/startContainers.ts` (+90 -0) ➕ `packages/plugins-queue-restate/src/tests/utils.ts` (+23 -0) ➕ `packages/plugins-queue-restate/tsconfig.json` (+10 -0) ➕ `packages/plugins-queue-restate/vitest.config.ts` (+14 -0) 📝 `packages/plugins-search-meilisearch/package.json` (+2 -2) 📝 `packages/shared-server/package.json` (+1 -0) _...and 4 more files_ </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 11:59:53 +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#1947

No description provided.

Rows
Columns