diff --git a/executorlib/interactive/shared.py b/executorlib/interactive/shared.py index 369c5c1e..2b0942bb 100644 --- a/executorlib/interactive/shared.py +++ b/executorlib/interactive/shared.py @@ -136,7 +136,9 @@ def __init__( super().__init__(max_cores=executor_kwargs.get("max_cores", None)) executor_kwargs["future_queue"] = self._future_queue executor_kwargs["spawner"] = spawner - executor_kwargs["queue_join_on_shutdown"] = False # The same queue is shared over multiple threads + executor_kwargs["queue_join_on_shutdown"] = ( + False # The same queue is shared over multiple threads + ) self._set_process( process=[ RaisingThread(