diff options
| author | Mohamed Bassem <me@mbassem.com> | 2025-11-09 20:13:39 +0000 |
|---|---|---|
| committer | Mohamed Bassem <me@mbassem.com> | 2025-11-09 20:13:39 +0000 |
| commit | b28cd03a4a5f95f429a1429a59319c8a9ac986f8 (patch) | |
| tree | f8b6a50338675bd0073643b5ff31fe447795fad4 /packages/plugins/queue-restate/src/index.ts | |
| parent | 03161482b44bd67f6eafb3e3d51107811b638d4b (diff) | |
| download | karakeep-b28cd03a4a5f95f429a1429a59319c8a9ac986f8.tar.zst | |
refactor: Allow runner functions to return results to onComplete
Diffstat (limited to 'packages/plugins/queue-restate/src/index.ts')
| -rw-r--r-- | packages/plugins/queue-restate/src/index.ts | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/packages/plugins/queue-restate/src/index.ts b/packages/plugins/queue-restate/src/index.ts index bedc26af..98668872 100644 --- a/packages/plugins/queue-restate/src/index.ts +++ b/packages/plugins/queue-restate/src/index.ts @@ -162,9 +162,9 @@ class RestateQueueClient implements QueueClient { return wrapper; } - createRunner<T>( + createRunner<T, R = void>( queue: Queue<T>, - funcs: RunnerFuncs<T>, + funcs: RunnerFuncs<T, R>, opts: RunnerOptions<T>, ): Runner<T> { const name = queue.name(); |