Fix breaking change for HighThroughputExecutor

globus · Apr 11, 2024 · 58cc4bb · 58cc4bb
1 parent 6f29ab7
commit 58cc4bb
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/changelog.d/20240411_134946_chris_hotfix.rst b/changelog.d/20240411_134946_chris_hotfix.rst
@@ -0,0 +1,5 @@
+Bug Fixes
+^^^^^^^^^
+
+- Fixed a bug that caused endpoints using the old ``HighThroughputExecutor`` to fail
+ silently.
diff --git a/compute_endpoint/globus_compute_endpoint/endpoint/interchange.py b/compute_endpoint/globus_compute_endpoint/endpoint/interchange.py
@@ -374,7 +374,7 @@ def process_pending_tasks() -> None:
  # gracefully, iterate once a second whether a task has arrived.
  nonlocal num_tasks_forwarded
  while not self._quiesce_event.is_set():
- if executor.executor_exception:
+ if getattr(executor, "executor_exception", False):
  self.time_to_quit = True
  log.exception(executor.executor_exception)