[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/run_pickled.py

@@ -2,6 +2,7 @@
 import pydra
 import sys
 
+
 def run_pickled(*file_paths, rerun=False):
     loaded_objects = []
 
@@ -18,6 +19,7 @@ def run_pickled(*file_paths, rerun=False):
 
     print(f"Result: {result}")
 
+
 if __name__ == "__main__":
     rerun = False  # Default value for rerun
     file_paths = sys.argv[1:]

pydra/engine/workers.py

@@ -911,7 +911,7 @@ def make_spec(self, cmd=None, arg=None):
         spec = self.psij.JobSpec()
         spec.executable = cmd
         spec.arguments = arg
-        
+
         return spec
 
     def make_job(self, spec, attributes):
@@ -963,16 +963,18 @@ async def exec_psij(self, runnable, rerun=False):
 
         spec.stdout_path = os.path.join(cache_dir, "demo.stdout")
         spec.stderr_path = os.path.join(cache_dir, "demo.stderr")
-        
+
         job = self.make_job(spec, None)
         jex.submit(job)
         job.wait()
 
         if os.path.getsize(spec.stderr_path) > 0:
             with open(spec.stderr_path, "r") as stderr_file:
                 stderr_contents = stderr_file.read()
-            raise Exception(f"stderr_path '{spec.stderr_path}' is not empty. Contents:\n{stderr_contents}")
-        
+            raise Exception(
+                f"stderr_path '{spec.stderr_path}' is not empty. Contents:\n{stderr_contents}"
+            )
+
         return
 
     def close(self):