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

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

Author: pre-commit-ci[bot]

pydra/engine/submitter.py

@@ -76,7 +76,6 @@ async def submit_from_call(self, runnable, rerun):
                 await self.expand_runnable(runnable, wait=True)
         return True
 
-
     async def expand_runnable(self, runnable, wait=False, rerun=False):
         """
         This coroutine handles state expansion.
@@ -117,10 +116,7 @@ async def expand_runnable(self, runnable, wait=False, rerun=False):
                     asyncio.create_task(load_and_run_async(task_pkl, sidx, self, rerun))
                 )
             else:
-                futures.add(
-                    self.worker.run_el((task_pkl, sidx, runnable), rerun=rerun)
-                )
-
+                futures.add(self.worker.run_el((task_pkl, sidx, runnable), rerun=rerun))
 
         if wait and futures:
             # if wait is True, we are at the end of the graph / state expansion.
@@ -130,7 +126,6 @@ async def expand_runnable(self, runnable, wait=False, rerun=False):
         # pass along futures to be awaited independently
         return futures
 
-
     async def expand_workflow(self, wf, rerun=False):
         """
         Expand and execute a stateless :class:`~pydra.engine.core.Workflow`.
@@ -278,11 +273,8 @@ def is_runnable(graph, obj):
     return True
 
 
-
 async def prepare_runnable_with_state(runnable):
     runnable.state.prepare_states(runnable.inputs, cont_dim=runnable.cont_dim)
     runnable.state.prepare_inputs()
-    logger.debug(
-        f"Expanding {runnable} into {len(runnable.state.states_val)} states"
-    )
-    return runnable.pickle_task()
+    logger.debug(f"Expanding {runnable} into {len(runnable.state.states_val)} states")
+    return runnable.pickle_task()

pydra/engine/workers.py

@@ -883,5 +883,5 @@ def close(self):
     "cf": ConcurrentFuturesWorker,
     "slurm": SlurmWorker,
     "dask": DaskWorker,
-    "sge": SGEWorker
+    "sge": SGEWorker,
 }