diff options
| author | Mohamed Bassem <me@mbassem.com> | 2025-11-10 09:54:42 +0000 |
|---|---|---|
| committer | Mohamed Bassem <me@mbassem.com> | 2025-11-10 09:54:42 +0000 |
| commit | d4b7b89ae201dddb8411add4bb6b99a60884fce1 (patch) | |
| tree | 304470a5b848c7e65d8766394604c8bf0f259029 /packages/plugins/queue-restate/src | |
| parent | d0f71a4c9e8e3a4ce56b486e429d3e455f67f07b (diff) | |
| download | karakeep-d4b7b89ae201dddb8411add4bb6b99a60884fce1.tar.zst | |
fix: stop retrying indefinitely in restate queues
Diffstat (limited to 'packages/plugins/queue-restate/src')
| -rw-r--r-- | packages/plugins/queue-restate/src/service.ts | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/packages/plugins/queue-restate/src/service.ts b/packages/plugins/queue-restate/src/service.ts index d19cad4c..8618b8ab 100644 --- a/packages/plugins/queue-restate/src/service.ts +++ b/packages/plugins/queue-restate/src/service.ts @@ -24,6 +24,15 @@ export function buildRestateService<T, R>( inactivityTimeout: { seconds: opts.timeoutSecs, }, + retryPolicy: { + maxAttempts: NUM_RETRIES, + initialInterval: { + seconds: 5, + }, + maxInterval: { + minutes: 1, + }, + }, }, handlers: { run: async ( |