Linter

Author: jsbueno

extraasync/__init__.py

@@ -6,4 +6,12 @@
 __version__ = "0.3.0"
 
 
-__all__ = ["aenumerate", "ExtraTaskGroup", "sync_to_async", "async_to_sync", "at_loop_stop_callback", "remove_loop_stop_callback",  "__version__"]
+__all__ = [
+    "aenumerate",
+    "ExtraTaskGroup",
+    "sync_to_async",
+    "async_to_sync",
+    "at_loop_stop_callback",
+    "remove_loop_stop_callback",
+    "__version__",
+]

extraasync/aenumerate.py

@@ -19,4 +19,3 @@ async def __aiter__(self):
 
     def __repr__(self):
         return f"Asynchronous enumeration for {self.iterable!r} at index {self.index!r}"
-

extraasync/async_hooks.py

@@ -7,8 +7,6 @@
 from asyncio import events
 from asyncio.events import AbstractEventLoop
 
-
-
 DEBUG = False
 
 
@@ -26,6 +24,7 @@ class Py313BaseEventLoop:
         into Python's asyncio BaseEventLoop
 
         """
+
         # Lib/asyncio/base_events.py
         def _run_forever_setup(self):
             """Prepare the run loop to process events.
@@ -42,7 +41,7 @@ def _run_forever_setup(self):
             self._thread_id = threading.get_ident()
             sys.set_asyncgen_hooks(
                 firstiter=self._asyncgen_firstiter_hook,
-                finalizer=self._asyncgen_finalizer_hook
+                finalizer=self._asyncgen_finalizer_hook,
             )
 
             events._set_running_loop(self)
@@ -82,17 +81,21 @@ def run_forever(self):
         ok_to_patch = False
 
     if not ok_to_patch:
-        raise RuntimeError("Python 3.12 requires patching asyncio before the async loop starts."
+        raise RuntimeError(
+            "Python 3.12 requires patching asyncio before the async loop starts."
             " Please import extraasync before setting up your async loop"
         )
-    asyncio.base_events.BaseEventLoop._run_forever_setup = Py313BaseEventLoop._run_forever_setup
-    asyncio.base_events.BaseEventLoop._run_forever_cleanup = Py313BaseEventLoop._run_forever_cleanup
+    asyncio.base_events.BaseEventLoop._run_forever_setup = (
+        Py313BaseEventLoop._run_forever_setup
+    )
+    asyncio.base_events.BaseEventLoop._run_forever_cleanup = (
+        Py313BaseEventLoop._run_forever_cleanup
+    )
     asyncio.base_events.BaseEventLoop.run_forever = Py313BaseEventLoop.run_forever
 
     # Now, it is "B.A.U."
 
 
-
 if not hasattr(asyncio.BaseEventLoop, "_run_forever_cleanup"):
 
     warnings.warn(
@@ -150,16 +153,14 @@ def new_run_forever_cleanup():
                 cb()
             except Exception as exc:
                 if not DEBUG:
-                    warnings.warn(
-                        f"""\
+                    warnings.warn(f"""\
                         Supressed Exception raised on loop callback {cb.__name__}:
                             {exc}
 
                         set extraasync.async_hooks.DEBUG to True
                         to have it raised instead.
 
-                    """
-                    )
+                    """)
                 else:
                     raise exc
         original_clean_up()

extraasync/sync_async_bridge.py

@@ -152,15 +152,11 @@ def _sync_to_async_non_bridge(
         try:
             loop = asyncio.new_event_loop()
         except RuntimeError:
-            raise RuntimeError(
-                D(
-                    """\
+            raise RuntimeError(D("""\
                 Error trying to create a new async loop - to be able to call 'sync_to_async' from
                 code inside a running async loop, the parent 'sync execution branch' must be called
                 with `extraasync.async_to_sync`.
-                """
-                )
-            )
+                """))
         _non_bridge_loop.set(loop)
 
     return loop.run_until_complete(coro)