diff options
| author | Mohamed Bassem <me@mbassem.com> | 2025-12-15 15:48:07 +0000 |
|---|---|---|
| committer | Mohamed Bassem <me@mbassem.com> | 2025-12-15 15:48:07 +0000 |
| commit | 510174db9661815de3c9b3dd8deb00c9db582054 (patch) | |
| tree | 98b2a15fdf623097333868687c08b02a3f9754c4 /packages/plugins/queue-restate/src/service.ts | |
| parent | 7f4202afd73105b850498b55ad66922b3505f0e3 (diff) | |
| download | karakeep-510174db9661815de3c9b3dd8deb00c9db582054.tar.zst | |
Revert "fix: fix restate service to return control to restate service on timeout"
This reverts commit 6db14ac492cd5d9e26d0d986513771f14faa7fd0.
Diffstat (limited to 'packages/plugins/queue-restate/src/service.ts')
| -rw-r--r-- | packages/plugins/queue-restate/src/service.ts | 9 |
1 files changed, 1 insertions, 8 deletions
diff --git a/packages/plugins/queue-restate/src/service.ts b/packages/plugins/queue-restate/src/service.ts index fb7e08c2..5ba7d1df 100644 --- a/packages/plugins/queue-restate/src/service.ts +++ b/packages/plugins/queue-restate/src/service.ts @@ -121,14 +121,7 @@ async function runWorkerLogic<T, R>( ctx.run( `main logic`, async () => { - return await Promise.race([ - run(data), - new Promise<R>((_, reject) => { - data.abortSignal.addEventListener("abort", () => { - reject(new Error(`Job didn't complete within timeout`)); - }); - }), - ]); + return await run(data); }, { maxRetryAttempts: 1, |