From 3546ae5e0923e63279a6c201b5f3c831aba17cce Mon Sep 17 00:00:00 2001 From: Nicola Soranzo Date: Tue, 17 Dec 2024 15:34:12 +0000 Subject: [PATCH] Pass ``timeout`` to ``ProcessPool.submit()`` as positional parameter It was made positional-only in commit: https://github.com/noxdafox/pebble/commit/6a12ddf1faecd73ea4b8d58515cadebfd2ca1f20 --- lib/galaxy/celery/tasks.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/galaxy/celery/tasks.py b/lib/galaxy/celery/tasks.py index 35b133fd5845..7c1d75dbb86a 100644 --- 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: