fix: issue with distributing tests with pytest -n auto

Author: adi611

pydra/engine/run_pickled_function.py

@@ -2,14 +2,16 @@
 import pydra
 import sys
 
+
 def run_pickled():
     file_path = sys.argv[1]
     with open(file_path, 'rb') as file:
         loaded_function = pickle.load(file)
 
     result = loaded_function(rerun=False)
-    
-    print(f'Result: {result}')
 
-if __name__ == '__main__':
+    print(f"Result: {result}")
+
+
+if __name__ == "__main__":
     run_pickled()

pydra/engine/run_pickled_function_2.py

@@ -2,6 +2,7 @@
 import pydra
 import sys
 
+
 def run_pickled():
     file_path_1 = sys.argv[1]
     file_path_2 = sys.argv[2]
@@ -15,7 +16,8 @@ def run_pickled():
 
     result = loaded_function(taskmain, ind, rerun=False)
 
-    print(f'Result: {result}')    
+    print(f"Result: {result}")
+
 
-if __name__ == '__main__':
+if __name__ == "__main__":
     run_pickled()

pydra/engine/workers.py

@@ -910,8 +910,8 @@ def make_spec(self, cmd=None, arg=None):
         spec = self.psij.JobSpec()
         spec.executable = cmd
         spec.arguments = arg
-        spec.stdout_path = '/pydra/pydra/engine/demo.stdout'
-        spec.stderr_path = '/pydra/pydra/engine/demo.stderr'
+        spec.stdout_path = "/pydra/pydra/engine/demo.stdout"
+        spec.stderr_path = "/pydra/pydra/engine/demo.stderr"
 
         return spec
 
@@ -950,13 +950,14 @@ async def exec_psij(self, runnable, rerun=False):
         job = self.make_job(spec, None)
         jex.submit(job)
         job.wait()
-        
+
         return
 
     def close(self):
         """Finalize the internal pool of tasks."""
         pass
 
+
 WORKERS = {
     "serial": SerialWorker,
     "cf": ConcurrentFuturesWorker,