diff options
| author | Mohamed Bassem <me@mbassem.com> | 2026-01-10 11:35:19 +0000 |
|---|---|---|
| committer | Mohamed Bassem <me@mbassem.com> | 2026-01-10 15:13:06 +0000 |
| commit | aace8864d7eab5c858a92064b0ac59c122377830 (patch) | |
| tree | 759ea7cd0666a947c3257a8a57d815938ae2bfa5 | |
| parent | 35a259dd189e825431a6cbbd7eb425514d5616f0 (diff) | |
| download | karakeep-aace8864d7eab5c858a92064b0ac59c122377830.tar.zst | |
fix: fix propagation of last error in restate
| -rw-r--r-- | packages/plugins/queue-restate/src/service.ts | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/packages/plugins/queue-restate/src/service.ts b/packages/plugins/queue-restate/src/service.ts index f27fd200..9529dae3 100644 --- a/packages/plugins/queue-restate/src/service.ts +++ b/packages/plugins/queue-restate/src/service.ts @@ -104,6 +104,7 @@ export function buildRestateService<T, R>( await ctx.sleep(1000, "error retry"); runNumber++; } else { + lastError = undefined; // Success break; } |