Force result_watcher shutdown

Parsl · Jan 15, 2025 · 464c202 · 464c202
1 parent b6510ee
commit 464c202
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/parsl/executors/globus_compute.py b/parsl/executors/globus_compute.py
@@ -117,5 +117,9 @@ def shutdown(self):
 
         GCE.shutdown will cancel all futures that have not yet registered with
         Globus Compute and will not wait for the launched futures to complete.
+        This method explicitly shutsdown the result_watcher thread to avoid
+        it waiting for outstanding futures at thread exit.
         """
         self.executor.shutdown(wait=False, cancel_futures=True)
+        result_watcher = self.executor._get_result_watcher()
+        result_watcher.shutdown(wait=False, cancel_futures=True)