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

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

pydra/engine/workers.py

@@ -891,6 +891,7 @@ def close(self):
         """Finalize the internal pool of tasks."""
         pass
 
+
 class PsijWorker(Worker):
     def __init__(self, **kwargs):
         """Initialize worker."""
@@ -909,8 +910,8 @@ def make_spec(self, cmd=None, arg=None, cache_dir=None):
         spec = self.psij.JobSpec()
         spec.executable = cmd
         spec.arguments = arg
-        spec.stdout_path = 'demo.stdout'
-        spec.stderr_path = 'demo.stderr'
+        spec.stdout_path = "demo.stdout"
+        spec.stderr_path = "demo.stderr"
 
         return spec
 
@@ -921,9 +922,12 @@ def make_job(self, spec, attributes):
 
     async def exec_psij(self, runnable, rerun=False):
         import psij
+
         self.psij = psij
-        jex = psij.JobExecutor.get_instance('local')
-        spec = self.make_spec(runnable.inputs.executable, runnable.inputs.args, runnable.cache_dir)
+        jex = psij.JobExecutor.get_instance("local")
+        spec = self.make_spec(
+            runnable.inputs.executable, runnable.inputs.args, runnable.cache_dir
+        )
         job = self.make_job(spec, None)
         jex.submit(job)
         return
@@ -932,6 +936,7 @@ def close(self):
         """Finalize the internal pool of tasks."""
         pass
 
+
 WORKERS = {
     "serial": SerialWorker,
     "cf": ConcurrentFuturesWorker,