YAPF run

Author: smurfix

tests/aiotest/test_timer.py

@@ -16,7 +16,7 @@ def display_date(end_time, loop):
             if not end_time:
                 end_time.append(loop.time() + delay * count)
             result.append(datetime.datetime.now())
-            if (loop.time() + delay*1.5) < end_time[0]:
+            if (loop.time() + delay * 1.5) < end_time[0]:
                 loop.call_later(delay, display_date, end_time, loop)
             else:
                 loop.stop(h)

tests/conftest.py

@@ -10,16 +10,21 @@
 import inspect
 
 # Hacks for <3.7
-if not hasattr(asyncio,'current_task'):
+if not hasattr(asyncio, 'current_task'):
+
     def current_task(loop=None):
         return asyncio.Task.current_task(loop)
+
     asyncio.current_task = current_task
 
-if not hasattr(asyncio,'all_tasks'):
+if not hasattr(asyncio, 'all_tasks'):
+
     def all_tasks(loop=None):
         return asyncio.Task.all_tasks(loop)
+
     asyncio.all_tasks = all_tasks
 
+
 @pytest.fixture
 async def loop():
     async with trio_asyncio.open_loop() as loop:
@@ -35,9 +40,9 @@ def sync_loop():
     with loop:
         yield loop
 
+
 # auto-trio-ize all async functions
 @pytest.hookimpl(tryfirst=True)
 def pytest_pyfunc_call(pyfuncitem):
     if inspect.iscoroutinefunction(pyfuncitem.obj):
         pyfuncitem.obj = pytest.mark.trio(pyfuncitem.obj)
-

tests/python/test_tasks.py

@@ -1793,7 +1793,6 @@ def foo():
 
     @unittest.skipUnless(PY34, 'need python 3.4 or later')
     def test_log_destroyed_pending_task(self):
-
         @asyncio.coroutine
         def kill_me(loop):
             future = self.new_future(loop)

trio_asyncio/base.py

@@ -135,7 +135,7 @@ class BaseTrioEventLoop(asyncio.SelectorEventLoop):
 
     def __init__(self, queue_len=None):
         if queue_len is None:
-            queue_len=1000
+            queue_len = 1000
 
         # Processing queue
         self._q = trio.Queue(queue_len)
@@ -432,7 +432,7 @@ async def synchronize(self):
 
         """
         w = trio.Event()
-        self._queue_handle(Handle(w.set,(),self, is_sync=True))
+        self._queue_handle(Handle(w.set, (), self, is_sync=True))
         await w.wait()
 
     # Signal handling #