YAPFd

Author: smurfix

setup.py

@@ -50,7 +50,7 @@
 
 """
 
-install_requires=[
+install_requires = [
     "trio",
     "async_generator >= 1.6",
 ]

tests/conftest.py

@@ -36,16 +36,19 @@ def all_tasks(loop=None):
 if not hasattr(asyncio, 'create_task'):
 
     if hasattr(asyncio.events, 'get_running_loop'):
+
         def create_task(coro):
             loop = asyncio.events.get_running_loop()
             return loop.create_task(coro)
     else:
+
         def create_task(coro):
             loop = asyncio.events._get_running_loop()
             return loop.create_task(coro)
 
     asyncio.create_task = create_task
 
+
 @pytest.fixture
 async def loop():
     async with trio_asyncio.open_loop() as loop:

tests/python/test_tasks.py

@@ -2049,13 +2049,12 @@ def test_create_task_with_noncoroutine(self):
         for x in range(2):
             try:
                 self.new_task(self.loop, 123)
-            except (TypeError,AssertionError):
+            except (TypeError, AssertionError):
                 pass
             else:
                 self.fail("Error not raised")
 
     def test_create_task_with_oldstyle_coroutine(self):
-
         @asyncio.coroutine
         def coro():
             pass
@@ -2071,7 +2070,6 @@ def coro():
         self.loop.run_until_complete(task)
 
     def test_create_task_with_async_function(self):
-
         async def coro():
             pass
 
@@ -2097,7 +2095,6 @@ def test_create_task_with_asynclike_function(self):
         self.assertEqual(self.loop.run_until_complete(task), 42)
 
     def test_bare_create_task(self):
-
         async def inner():
             return 1
 
@@ -2177,8 +2174,7 @@ def test_context_3(self):
         async def sub(num):
             for i in range(10):
                 cvar.set(num + i)
-                await asyncio.sleep(
-                    random.uniform(0.001, 0.05), loop=loop)
+                await asyncio.sleep(random.uniform(0.001, 0.05), loop=loop)
                 self.assertEqual(cvar.get(), num + i)
 
         async def main():
@@ -2662,8 +2658,7 @@ def test_run_coroutine_threadsafe_task_factory_exception(self):
         def task_factory(loop, coro):
             raise NameError
 
-        run = self.loop.run_in_executor(
-            None, lambda: self.target(advance_coro=True))
+        run = self.loop.run_in_executor(None, lambda: self.target(advance_coro=True))
 
         # Set exception handler
         callback = test_utils.MockCallback()
@@ -2711,6 +2706,7 @@ def coro():
         self.loop.run_until_complete(coro())
         self.assertEqual(result, 11)
 
+
 class CompatibilityTests(test_utils.TestCase):
     # Tests for checking a bridge between old-styled coroutines
     # and async/await syntax
@@ -2726,7 +2722,6 @@ def tearDown(self):
         super().tearDown()
 
     def test_yield_from_awaitable(self):
-
         @asyncio.coroutine
         def coro():
             yield from asyncio.sleep(0, loop=self.loop)
@@ -2736,7 +2731,6 @@ def coro():
         self.assertEqual('ok', result)
 
     def test_await_old_style_coro(self):
-
         @asyncio.coroutine
         def coro1():
             return 'ok1'
@@ -2745,6 +2739,7 @@ def coro1():
         def coro2():
             yield from asyncio.sleep(0, loop=self.loop)
             return 'ok2'
+
         async def inner():
             return await asyncio.gather(coro1(), coro2(), loop=self.loop)
 
@@ -2754,7 +2749,8 @@ async def inner():
     @unittest.skipIf(sys.version_info < (3, 7), 'need python 3.7 for asyncio.run')
     def test_debug_mode_interop(self):
         # https://bugs.python.org/issue32636
-        code = textwrap.dedent("""
+        code = textwrap.dedent(
+            """
             import asyncio
 
             async def native_coro():
@@ -2765,7 +2761,8 @@ def old_style_coro():
                 yield from native_coro()
 
             asyncio.run(old_style_coro())
-        """)
+        """
+        )
         assert_python_ok("-c", code, PYTHONASYNCIODEBUG="1")