Skip to content

Commit 815ed41

Browse files
committed
Merge remote-tracking branch 'origin/main' into serialize_funct_h5
# Conflicts: # executorlib/interactive/shared.py
2 parents 6c5853a + e67db60 commit 815ed41

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

executorlib/base/executor.py

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -116,10 +116,11 @@ def shutdown(self, wait: bool = True, *, cancel_futures: bool = False):
116116
"""
117117
if cancel_futures:
118118
cancel_items_in_queue(que=self._future_queue)
119-
self._future_queue.put({"shutdown": True, "wait": wait})
120-
if wait and self._process is not None:
121-
self._process.join()
122-
self._future_queue.join()
119+
if self._process is not None:
120+
self._future_queue.put({"shutdown": True, "wait": wait})
121+
if wait:
122+
self._process.join()
123+
self._future_queue.join()
123124
self._process = None
124125
self._future_queue = None
125126

0 commit comments

Comments
 (0)