reformat

Author: egorsmkv

benchmarks/compare_event_loops.py

@@ -428,7 +428,9 @@ def child_main(args: argparse.Namespace) -> int:
                 raise RuntimeError("profiling is only supported for rsloop")
             rsloop = importlib.import_module("rsloop")
             if args.profile_label:
-                print(f"[profile] Tracy session label: {args.profile_label}", flush=True)
+                print(
+                    f"[profile] Tracy session label: {args.profile_label}", flush=True
+                )
             with rsloop.profile():
                 result = run_with_loop(args.loop, coro)
         else:

python/rsloop/__init__.py

@@ -386,7 +386,9 @@ def sendto(self, data, addr=None):
                 return
             except (BlockingIOError, InterruptedError):
                 if self._writer_task is None:
-                    self._writer_task = self._loop.create_task(self._flush_write_buffer())
+                    self._writer_task = self._loop.create_task(
+                        self._flush_write_buffer()
+                    )
             except OSError as exc:
                 self._protocol.error_received(exc)
                 return
@@ -493,7 +495,9 @@ async def __loop_sock_sendto(self, sock, data, address):
             await __wait_for_fd(self, sock, readable=False)
 
 
-async def __loop_sendfile(self, transport, file, offset=0, count=None, *, fallback=True):
+async def __loop_sendfile(
+    self, transport, file, offset=0, count=None, *, fallback=True
+):
     if transport.is_closing():
         raise RuntimeError("Transport is closing")
     if not fallback:
@@ -531,7 +535,9 @@ async def drain_transport() -> None:
             file.seek(offset + total_sent)
 
 
-async def __loop_sock_sendfile(self, sock, file, offset=0, count=None, *, fallback=True):
+async def __loop_sock_sendfile(
+    self, sock, file, offset=0, count=None, *, fallback=True
+):
     if sock.gettimeout() != 0:
         raise ValueError("the socket must be non-blocking")
     if "b" not in getattr(file, "mode", "b"):
@@ -598,7 +604,9 @@ async def __loop_create_datagram_endpoint(
 ):
     resolved_remote_addr = None
     if sock is not None and (local_addr is not None or remote_addr is not None):
-        raise ValueError("socket modifier keyword arguments can not be used when sock is specified")
+        raise ValueError(
+            "socket modifier keyword arguments can not be used when sock is specified"
+        )
     if sock is None and local_addr is None and remote_addr is None:
         raise ValueError("unexpected address family")
 
@@ -1623,7 +1631,9 @@ async def wrapper():
             try:
                 __cancel_all_tasks(loop)
                 loop.run_until_complete(loop.shutdown_asyncgens())
-                shutdown_default_executor = getattr(loop, "shutdown_default_executor", None)
+                shutdown_default_executor = getattr(
+                    loop, "shutdown_default_executor", None
+                )
                 if shutdown_default_executor is not None:
                     loop.run_until_complete(shutdown_default_executor())
             finally:

tests/test_compat.py

@@ -204,7 +204,9 @@ def shutdown(self, wait):
                 await loop.run_in_executor(None, lambda: 1)
             except RuntimeError as exc:
                 return str(exc)
-            raise AssertionError("run_in_executor(None, ...) should fail after shutdown")
+            raise AssertionError(
+                "run_in_executor(None, ...) should fail after shutdown"
+            )
 
         self.assertEqual(
             rsloop.run(main()),
@@ -322,7 +324,9 @@ def shutdown(self, wait):
                 await loop.getaddrinfo("localhost", 80)
             except RuntimeError as exc:
                 return str(exc)
-            raise AssertionError("getaddrinfo should fail after default executor shutdown")
+            raise AssertionError(
+                "getaddrinfo should fail after default executor shutdown"
+            )
 
         self.assertEqual(
             rsloop.run(main()),
@@ -486,7 +490,9 @@ def connection_lost(self, exc):
             path = pathlib.Path(tmpdir) / "payload.bin"
             payload = b"sendfile-payload"
             path.write_bytes(payload)
-            self.assertEqual(rsloop.run(main(str(path), payload)), (len(payload), payload))
+            self.assertEqual(
+                rsloop.run(main(str(path), payload)), (len(payload), payload)
+            )
 
     def test_sock_recvfrom_receives_datagram(self) -> None:
         async def main() -> tuple[bytes, tuple[str, int]]: