Pass timeout to ProcessPool.submit() as positional parameter

It was made positional-only in commit: noxdafox/pebble@6a12ddf
galaxyproject · Dec 17, 2024 · 3546ae5 · 3546ae5
1 parent 5f7c3ba
commit 3546ae5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/galaxy/celery/tasks.py b/lib/galaxy/celery/tasks.py
@@ -289,7 +289,7 @@ def abort_when_job_stops(function: Callable, session: galaxy_scoped_session, job
     if not is_aborted(session, job_id):
         future = celery_app.fork_pool.submit(
             function,
-            timeout=None,
+            None,
             **kwargs,
         )
         while True: