Cancel ProcessPoolFuture when aborting job

Fixes the occasional timeout error in jobs that follow the `test_abort_fetch_job` test.
galaxyproject · May 2, 2024 · 1bea8a7 · 1bea8a7
1 parent acec4f6
commit 1bea8a7
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/lib/galaxy/celery/tasks.py b/lib/galaxy/celery/tasks.py
@@ -288,6 +288,7 @@ def abort_when_job_stops(function: Callable, session: galaxy_scoped_session, job
                 return future.result(timeout=1)
             except TimeoutError:
                 if is_aborted(session, job_id):
+                    future.cancel()
                     return