From 510174db9661815de3c9b3dd8deb00c9db582054 Mon Sep 17 00:00:00 2001
From: Mohamed Bassem <me@mbassem.com>
Date: Mon, 15 Dec 2025 15:48:07 +0000
Subject: Revert "fix: fix restate service to return control to restate service
 on timeout"

This reverts commit 6db14ac492cd5d9e26d0d986513771f14faa7fd0.
---
 packages/plugins/queue-restate/src/service.ts | 9 +--------
 1 file changed, 1 insertion(+), 8 deletions(-)

(limited to 'packages/plugins/queue-restate/src/service.ts')

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,
-- 
cgit v1.2.3-70-g09d2