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

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

Author: pre-commit-ci[bot]

pydra/workers/oar.py

@@ -139,7 +139,9 @@ async def run(self, job: "Job[base.TaskType]", rerun: bool = False) -> "Result":
                         # for pyt3.8 we could you missing_ok=True
                         (job.cache_root / f"{checksum}.lock").unlink()
                 cmd_re = ("oarstat", "-J", "--sql", f"resubmit_job_id='{jobid}'")
-                _, stdout, _ = await base.read_and_display_async(*cmd_re, hide_display=True)
+                _, stdout, _ = await base.read_and_display_async(
+                    *cmd_re, hide_display=True
+                )
                 if not stdout:
                     raise RuntimeError(
                         "Job information about resubmission of job {jobid} not found"

pydra/workers/tests/test_worker.py

@@ -626,7 +626,7 @@ def test_oar_wf_cf(tmpdir):
     wf.plugin = "cf"
     with Submitter(worker="oar", cache_root=tmpdir) as sub:
         res = sub(wf)
-    
+
     outputs = res.outputs
     assert outputs.out == 9
     script_dir = tmpdir / "oar_scripts"
@@ -672,7 +672,9 @@ def test_oar_args_2(tmpdir):
     task = SleepAddOne(x=1)
     # submit workflow and every task as oar job
     with pytest.raises(RuntimeError, match="Error returned from oarsub:"):
-        with Submitter(worker="oar", cache_root=tmpdir, oarsub_args="-l nodes=2 --invalid") as sub:
+        with Submitter(
+            worker="oar", cache_root=tmpdir, oarsub_args="-l nodes=2 --invalid"
+        ) as sub:
             sub(task)