YAPF me harder

Author: smurfix

docs/source/conf.py

@@ -30,7 +30,6 @@
     ("py:class", "CapacityLimiter-like object"),
     ("py:class", "bytes-like"),
     ("py:class", "None"),
-
     ("py:func", "trio_asyncio.wait_for_child"),
     ("py:func", "trio_asyncio.run_future"),
     ("py:func", "trio_asyncio.run_coroutine"),
@@ -118,7 +117,6 @@
 # If true, `todo` and `todoList` produce output, else they produce nothing.
 todo_include_todos = False
 
-
 # -- Options for HTML output ----------------------------------------------
 
 # The theme to use for HTML and HTML Help pages.  See the documentation for
@@ -152,13 +150,11 @@
 # so a file named "default.css" will overwrite the builtin "default.css".
 html_static_path = ['_static']
 
-
 # -- Options for HTMLHelp output ------------------------------------------
 
 # Output file base name for HTML help builder.
 htmlhelp_basename = 'trio-asyncio-doc'
 
-
 # -- Options for LaTeX output ---------------------------------------------
 
 latex_elements = {
@@ -183,28 +179,23 @@
 # (source start file, target name, title,
 #  author, documentclass [howto, manual, or own class]).
 latex_documents = [
-    (master_doc, 'trio-asyncio.tex', 'Trio Documentation',
-     author, 'manual'),
+    (master_doc, 'trio-asyncio.tex', 'Trio Documentation', author, 'manual'),
 ]
 
-
 # -- Options for manual page output ---------------------------------------
 
 # One entry per manual page. List of tuples
 # (source start file, name, description, authors, manual section).
-man_pages = [
-    (master_doc, 'trio-asyncio', 'trio-asyncio Documentation',
-     [author], 1)
-]
-
+man_pages = [(master_doc, 'trio-asyncio', 'trio-asyncio Documentation', [author], 1)]
 
 # -- Options for Texinfo output -------------------------------------------
 
 # Grouping the document tree into Texinfo files. List of tuples
 # (source start file, target name, title, author,
 #  dir menu entry, description, category)
 texinfo_documents = [
-    (master_doc, 'trio-asyncio', 'trio-asyncio Documentation',
-     author, 'trio-asyncio', 'A re-implementation of the asyncio mainloop on top of Trio',
-     'Miscellaneous'),
+    (
+        master_doc, 'trio-asyncio', 'trio-asyncio Documentation', author, 'trio-asyncio',
+        'A re-implementation of the asyncio mainloop on top of Trio', 'Miscellaneous'
+    ),
 ]

tests/conftest.py

@@ -64,4 +64,3 @@ async def loop():
 def pytest_pyfunc_call(pyfuncitem):
     if inspect.iscoroutinefunction(pyfuncitem.obj):
         pyfuncitem.obj = pytest.mark.trio(pyfuncitem.obj)
-

tests/python/test_base_events.py

@@ -108,7 +108,7 @@ def chk(inf):
             assert inf[4][0] == '::3'
             assert inf[4][1] == 1
             assert len(inf) == 5
-            assert len(inf[4]) in (2,4)
+            assert len(inf[4]) in (2, 4)
 
         chk(base_events._ipaddr_info('::3', 1, INET6, STREAM, TCP))
         chk(base_events._ipaddr_info('::3', 1, UNSPEC, STREAM, TCP))

tests/python/test_events.py

@@ -2394,7 +2394,10 @@ def __await__(self):
         # Some coroutines might not have '__name__', such as
         # built-in async_gen.asend().
 
-        self.assertEqual(coroutines._format_coroutine(coro), 'Coro()' if sys.version_info < (3, 7) else '<Coro without __name__>()')
+        self.assertEqual(
+            coroutines._format_coroutine(coro), 'Coro()'
+            if sys.version_info < (3, 7) else '<Coro without __name__>()'
+        )
 
 
 class TimerTests(unittest.TestCase):

tests/test_concurrent.py

@@ -58,15 +58,15 @@ def get_loop(i, loop, policy):
             assert isinstance(policy, trio_asyncio.TrioPolicy)
             async with trio_asyncio.open_loop() as loop2:
                 p2 = asyncio.get_event_loop_policy()
-                assert policy is p2, (policy,p2)
+                assert policy is p2, (policy, p2)
                 loop1.call_later(0.1, get_loop, 0, loop1, policy)
                 loop2.call_later(0.1, get_loop, 1, loop2, policy)
                 await trio.sleep(0.2)
 
     assert isinstance(asyncio.get_event_loop_policy(), trio_asyncio.TrioPolicy)
     assert asyncio._get_running_loop() is None
 
+
 def test_same_task():
     assert not isinstance(asyncio.get_event_loop_policy(), trio_asyncio.TrioPolicy)
     trio.run(_test_same_task)
-

tests/test_sync.py

@@ -16,4 +16,3 @@ async def bar():
         res = loop.run_until_complete(bar())
         assert res == "baz"
         loop.close()
-

trio_asyncio/loop.py

@@ -44,6 +44,7 @@
 # setter stores the policy in a thread-local variable to which our policy
 # will forward all requests when Trio is not running.
 
+
 class _TrioPolicy(asyncio.events.BaseDefaultEventLoopPolicy):
     _loop_factory = TrioEventLoop
 
@@ -122,6 +123,7 @@ def set_event_loop(self, loop):
 
 _orig_policy_get = _aio_event.get_event_loop_policy
 
+
 def _new_policy_get():
     try:
         task = trio.hazmat.current_task()
@@ -143,6 +145,7 @@ def _new_policy_get():
 
 _orig_policy_set = _aio_event.set_event_loop_policy
 
+
 def _new_policy_set(new_policy):
     if isinstance(new_policy, TrioPolicy):
         raise RuntimeError("You can't set the Trio loop policy manually")
@@ -163,7 +166,6 @@ def _new_policy_set(new_policy):
 _aio_event.set_event_loop_policy = _new_policy_set
 asyncio.set_event_loop_policy = _new_policy_set
 
-
 #####
 
 _orig_run_get = _aio_event._get_running_loop
@@ -227,10 +229,12 @@ def set_child_watcher(self, watcher):
                 watcher.attach_loop(loop)
         super().set_child_watcher(watcher)
 
+
 _original_policy = _orig_policy_get()
 _new_policy = TrioPolicy()
 _orig_policy_set(_new_policy)
 
+
 class TrioChildWatcher(asyncio.AbstractChildWatcher if sys.platform != 'win32' else object):
     # AbstractChildWatcher not available under Windows
     def __init__(self):
@@ -278,6 +282,7 @@ def wrap_generator(proc, *args):
         raise RuntimeError("Need to run in a trio_asyncio.open_loop() context")
     return loop.wrap_generator(proc, *args)
 
+
 def run_iterator(aiter):
     loop = asyncio.get_event_loop()
     if not isinstance(loop, TrioEventLoop):