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

for more information, see https://pre-commit.ci
nipype · Nov 29, 2022 · d196fa9 · d196fa9
1 parent 20b7a51
commit d196fa9
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/pydra/engine/workers.py b/pydra/engine/workers.py
@@ -58,7 +58,10 @@ async def fetch_finished(self, futures):
         done = set()
         try:
             done, pending = await asyncio.wait(
-                [asyncio.create_task(f) if not isinstance(f, asyncio.Task) else f for f in futures],
+                [
+                    asyncio.create_task(f) if not isinstance(f, asyncio.Task) else f
+                    for f in futures
+                ],
                 return_when=asyncio.FIRST_COMPLETED,
             )
         except ValueError:
@@ -106,7 +109,10 @@ async def fetch_finished(self, futures):
         try:
             self._jobs += len(futures)
             done, pending = await asyncio.wait(
-                [asyncio.create_task(f) if not isinstance(f, asyncio.Task) else f for f in futures],
+                [
+                    asyncio.create_task(f) if not isinstance(f, asyncio.Task) else f
+                    for f in futures
+                ],
                 return_when=asyncio.FIRST_COMPLETED,
             )
         except ValueError: