[pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

Author: pre-commit-ci[bot]

executorlib/executor/flux.py

@@ -359,10 +359,12 @@ def __init__(
             from executorlib.task_scheduler.file.task_scheduler import (
                 create_file_executor,
             )
+
             if terminate_tasks_on_shutdown:
                 from executorlib.task_scheduler.file.queue_spawner import (
                     terminate_with_pysqa,
                 )
+
                 terminate_function = terminate_with_pysqa
             else:
                 terminate_function = None

executorlib/executor/slurm.py

@@ -165,10 +165,12 @@ def __init__(
             from executorlib.task_scheduler.file.task_scheduler import (
                 create_file_executor,
             )
+
             if terminate_tasks_on_shutdown:
                 from executorlib.task_scheduler.file.queue_spawner import (
                     terminate_with_pysqa,
                 )
+
                 terminate_function = terminate_with_pysqa
             else:
                 terminate_function = None

executorlib/standalone/inputcheck.py

@@ -223,4 +223,4 @@ def check_terminate_tasks_on_shutdown(terminate_tasks_on_shutdown: bool) -> None
             "terminate_tasks_on_shutdown is not supported for the executorlib.SingleNodeExecutor, "
             "executorlib.SlurmJobExecutor and executorlib.FluxJobExecutor."
             "Please use terminate_tasks_on_shutdown=True instead of terminate_tasks_on_shutdown=False."
-        )
+        )

executorlib/task_scheduler/file/shared.py

@@ -10,9 +10,7 @@
 from executorlib.standalone.command import get_command_path
 from executorlib.standalone.serialize import serialize_funct_h5
 from executorlib.task_scheduler.file.hdf import dump, get_output
-from executorlib.task_scheduler.file.subprocess_spawner import (
-    terminate_subprocess
-)
+from executorlib.task_scheduler.file.subprocess_spawner import terminate_subprocess
 
 
 class FutureItem:
@@ -89,7 +87,10 @@ def execute_tasks_h5(
         with contextlib.suppress(queue.Empty):
             task_dict = future_queue.get_nowait()
         if task_dict is not None and "shutdown" in task_dict and task_dict["shutdown"]:
-            if terminate_function is not None and terminate_function == terminate_subprocess:
+            if (
+                terminate_function is not None
+                and terminate_function == terminate_subprocess
+            ):
                 for task in process_dict.values():
                     terminate_function(task=task)
             elif terminate_function is not None: