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

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

Author: pre-commit-ci[bot]

benchmarks/cluster_start.py

@@ -15,7 +15,7 @@ def start_cluster(depth, number_of_engines, path='', log_output_to_file=False):
         f'--HubFactory.db_class=NoDB'
     )
     print(ipcontroller_cmd)
-    ipengine_cmd = f'{path}ipengine --profile=asv ' f'--cluster-id=depth_{depth} '
+    ipengine_cmd = f'{path}ipengine --profile=asv --cluster-id=depth_{depth} '
     ps = [
         Popen(
             ipcontroller_cmd.split(),

ipyparallel/controller/app.py

@@ -712,9 +712,9 @@ def load_config_from_json(self):
             ccfg = json.loads(f.read())
 
         for key in ('key', 'registration', 'pack', 'unpack', 'signature_scheme'):
-            assert (
-                ccfg[key] == ecfg[key]
-            ), f"mismatch between engine and client info: {key!r}"
+            assert ccfg[key] == ecfg[key], (
+                f"mismatch between engine and client info: {key!r}"
+            )
 
         xport, ip = ccfg['interface'].split('://')
 

ipyparallel/controller/heartmonitor.py

@@ -106,8 +106,7 @@ class HeartMonitor(LoggingConfigurable):
     period = Integer(
         3000,
         config=True,
-        help='The frequency at which the Hub pings the engines for heartbeats '
-        '(in ms)',
+        help='The frequency at which the Hub pings the engines for heartbeats (in ms)',
     )
     max_heartmonitor_misses = Integer(
         10,

ipyparallel/controller/hub.py

@@ -564,8 +564,7 @@ def save_broadcast_request(self, idents, msg):
             msg = self.session.deserialize(msg)
         except Exception as e:
             self.log.error(
-                f'broadcast:: client {client_id} sent invalid broadcast message:'
-                f' {msg}',
+                f'broadcast:: client {client_id} sent invalid broadcast message: {msg}',
                 exc_info=True,
             )
             return
@@ -588,7 +587,7 @@ def save_broadcast_result(self, idents, msg):
             msg = self.session.deserialize(msg)
         except Exception as e:
             self.log.error(
-                f'broadcast::invalid broadcast result message send to {client_id}:' f''
+                f'broadcast::invalid broadcast result message send to {client_id}:'
             )
 
         # save the result of a completed broadcast

ipyparallel/tests/clienttest.py

@@ -107,9 +107,9 @@ def raises_remote(etype):
             e.raise_exception()
     except error.RemoteError as e:
         tb = '\n'.join(e.render_traceback())
-        assert (
-            expected_ename == e.ename
-        ), f"Should have raised {expected_ename}, but raised {e.ename}:\n{tb}"
+        assert expected_ename == e.ename, (
+            f"Should have raised {expected_ename}, but raised {e.ename}:\n{tb}"
+        )
 
     else:
         pytest.fail("should have raised a RemoteError")

ipyparallel/tests/test_asyncresult.py

@@ -242,9 +242,9 @@ def test_hubresult_timestamps(self):
             hr = rc2.get_result(ar.msg_ids)
             assert hr.elapsed > 0.0, f"got bad elapsed: {hr.elapsed}"
             hr.get(1)
-            assert (
-                hr.wall_time < ar.wall_time + 0.2
-            ), f"got bad wall_time: {hr.wall_time} > {ar.wall_time}"
+            assert hr.wall_time < ar.wall_time + 0.2, (
+                f"got bad wall_time: {hr.wall_time} > {ar.wall_time}"
+            )
             assert hr.serial_time == ar.serial_time
         finally:
             rc2.close()

ipyparallel/tests/test_cluster.py

@@ -168,7 +168,7 @@ async def test_restart_engines(Cluster):
             await asyncio.sleep(0.1)
             if time.monotonic() > deadline:
                 raise TimeoutError(
-                    f"timeout waiting for engines 0-{n-1} to unregister, {rc.ids=}"
+                    f"timeout waiting for engines 0-{n - 1} to unregister, {rc.ids=}"
                 )
         # wait for register
         rc.wait_for_engines(n, timeout=_timeout)

ipyparallel/tests/test_dependency.py

@@ -38,19 +38,19 @@ def assertMet(self, dep):
         assert dep.check(self.succeeded, self.failed), "Dependency should be met"
 
     def assertUnmet(self, dep):
-        assert not dep.check(
-            self.succeeded, self.failed
-        ), "Dependency should not be met"
+        assert not dep.check(self.succeeded, self.failed), (
+            "Dependency should not be met"
+        )
 
     def assertUnreachable(self, dep):
-        assert dep.unreachable(
-            self.succeeded, self.failed
-        ), "Dependency should be unreachable"
+        assert dep.unreachable(self.succeeded, self.failed), (
+            "Dependency should be unreachable"
+        )
 
     def assertReachable(self, dep):
-        assert not dep.unreachable(
-            self.succeeded, self.failed
-        ), "Dependency should be reachable"
+        assert not dep.unreachable(self.succeeded, self.failed), (
+            "Dependency should be reachable"
+        )
 
     def cancan(self, f):
         """decorator to pass through canning into self.user_ns"""

ipyparallel/tests/test_magics.py

@@ -324,9 +324,9 @@ def test_cellpx_stream(self):
         # Check that all expected lines are in the output
         self._check_expected_lines_unordered(expected, lines)
 
-        assert (
-            len(expected) - len(v) <= len(lines) <= len(expected)
-        ), f"expected {len(expected)} lines, got: {io.stdout}"
+        assert len(expected) - len(v) <= len(lines) <= len(expected), (
+            f"expected {len(expected)} lines, got: {io.stdout}"
+        )
 
         # Do the same for stderr
         print(io.stderr, file=sys.stderr)
@@ -343,9 +343,9 @@ def test_cellpx_stream(self):
             * len(v)
         )
         self._check_expected_lines_unordered(expected, lines)
-        assert (
-            len(expected) - len(v) <= len(lines) <= len(expected)
-        ), f"expected {len(expected)} lines, got: {io.stderr}"
+        assert len(expected) - len(v) <= len(lines) <= len(expected), (
+            f"expected {len(expected)} lines, got: {io.stderr}"
+        )
 
     def test_px_nonblocking(self):
         ip = get_ipython()

ipyparallel/tests/test_view.py

@@ -933,9 +933,9 @@ def test_cloudpickle_require(self):
         view = self.client[:]
         # enable cloudpickle
         view.use_cloudpickle()
-        assert (
-            'types' not in globals()
-        ), "Test condition isn't met if types is already imported"
+        assert 'types' not in globals(), (
+            "Test condition isn't met if types is already imported"
+        )
 
         @ipp.require("types")
         @ipp.interactive