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

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

examples/simple-client-thrift.py

@@ -50,8 +50,7 @@ async def call() -> None:
                 await peer.invoke("simple", adaptor.long_delay())
         except asyncio.TimeoutError:
             print(
-                "long_delay(): timeout occurred as expected "
-                "(with per-call timeout)"
+                "long_delay(): timeout occurred as expected (with per-call timeout)"
             )
         else:
             print("long_delay(): timeout did not occur!")
@@ -61,8 +60,7 @@ async def call() -> None:
             await peer.invoke("simple", adaptor.long_delay())
         except asyncio.TimeoutError:
             print(
-                "long_delay(): timeout occurred as expected "
-                "(with default timeout)"
+                "long_delay(): timeout occurred as expected (with default timeout)"
             )
         else:
             print("long_delay(): timeout did not occur!")

examples/simple-client.py

@@ -50,9 +50,7 @@ async def test_timeout(peer):
                 },
             )
     except asyncio.TimeoutError:
-        print(
-            "long_delay(): timeout occurred as expected " "(with per-call timeout)"
-        )
+        print("long_delay(): timeout occurred as expected (with per-call timeout)")
     except Exception as e:
         print("long_delay(): unexpected error", e)
         sys.exit(1)
@@ -68,7 +66,7 @@ async def test_timeout(peer):
             },
         )
     except asyncio.TimeoutError:
-        print("long_delay(): timeout occurred as expected " "(with default timeout)")
+        print("long_delay(): timeout occurred as expected (with default timeout)")
     except Exception as e:
         print("long_delay(): unexpected error", e)
         sys.exit(1)

src/callosum/lower/zeromq.py

@@ -141,9 +141,9 @@ async def handle_zap_message(self, msg) -> None:
             )
             allowed = result.success
             if allowed:
-                assert (
-                    result.user_id is not None
-                ), "expected valid user ID from check_client() callback"
+                assert result.user_id is not None, (
+                    "expected valid user ID from check_client() callback"
+                )
                 user_id = result.user_id
         else:
             # In Callosum, we only support public-key based authentication.

src/callosum/ordering.py

@@ -184,7 +184,7 @@ async def cancel(self, request_id) -> None:
             # The scheduler caller (upper) will call cleanup.
         else:
             self._log.warning(
-                "cancellation of unknown or " "not sent yet request: %r", request_id
+                "cancellation of unknown or not sent yet request: %r", request_id
             )