ARQ use context options for result timeout

Flared · May 9, 2024 · fa4b783 · fa4b783
1 parent 7ebce5f
commit fa4b783
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/saturn_engine/worker/executors/arq/executor.py b/src/saturn_engine/worker/executors/arq/executor.py
@@ -114,7 +114,7 @@ async def process_message(self, message: ExecutableMessage) -> PipelineResults:
 
         tasks = TasksGroup(name=f"saturn.arq.process_message({message.id})")
         result_task: asyncio.Task[PipelineResults] = tasks.create_task(
-            job.result(timeout=self.options.timeout)
+            job.result(timeout=options.timeout)
         )
         healthcheck_task = tasks.create_task(self.monitor_job_healthcheck(job))
         async with tasks: