No more flake8 warnings

also yapf3 formatted
also changed max line length to 99 characters

Author: smurfix

.style.yapf

@@ -45,7 +45,7 @@ blank_line_before_nested_class_or_def=False
 coalesce_brackets=False
 
 # The column limit.
-column_limit=79
+column_limit=99
 
 # Indent width used for line continuations.
 continuation_indent_width=4

setup.cfg

@@ -1,4 +1,6 @@
 [aliases]
 test=pytest
-
+[flake8]
+max-line-length=99
+ignore=E402,E731,E127
 

tests/aiotest/__init__.py

@@ -9,12 +9,6 @@
 else:
     socketpair = socket.socketpair
 
-import unittest
-try:
-    from unittest import mock
-except ImportError:
-    import mock
-
 
 class TestConfig:
     def __init__(self):
@@ -59,17 +53,20 @@ def __init__(self):
         self.stopping = True
 
     def prepare(self, testcase):
-        #import pdb;pdb.set_trace()
-        #policy = self.new_event_pool_policy()
-        #self.asyncio.set_event_loop_policy(policy)
+        # import pdb;pdb.set_trace()
+        # policy = self.new_event_pool_policy()
+        # self.asyncio.set_event_loop_policy(policy)
         testcase.addCleanup(self.asyncio.set_event_loop_policy, None)
 
         testcase.loop = self.asyncio.get_event_loop()
-        #testcase.addCleanup(testcase.loop.close)
-        #testcase.addCleanup(self.asyncio.set_event_loop, None)
+        # testcase.addCleanup(testcase.loop.close)
+        # testcase.addCleanup(self.asyncio.set_event_loop, None)
+
 
 class TestCase:
     pass
+
+
 #    @classmethod
 #    def setUpClass(cls):
 #        cls.config = config

tests/aiotest/conftest.py

@@ -1,7 +1,7 @@
 import pytest
 from . import TestConfig
 
+
 @pytest.fixture
 def config():
     return TestConfig()
-

tests/aiotest/test_add_reader.py

@@ -1,16 +1,17 @@
 from __future__ import absolute_import
 from tests.aiotest import socketpair
-from tests import aiotest
 import pytest
 import trio
 
+
 class TestAddReader:
     @pytest.mark.trio
     async def test_add_reader(self, loop):
         result = {'received': None}
         rsock, wsock = socketpair()
         ready = trio.Event()
         try:
+
             def reader():
                 data = rsock.recv(100)
                 result['received'] = data
@@ -38,16 +39,19 @@ async def check_add_replace(self, event, loop, config):
         if event == 'reader':
             add_sock = loop.add_reader
             remove_sock = loop.remove_reader
+
             def get_handle(fileobj):
                 return selector.get_key(fileobj).data[0]
         else:
             add_sock = loop.add_writer
             remove_sock = loop.remove_writer
+
             def get_handle(fileobj):
                 return selector.get_key(fileobj).data[1]
 
         sock = socket.socket()
         try:
+
             def func():
                 pass
 
@@ -83,4 +87,3 @@ async def test_add_reader_replace(self, loop, config):
     @pytest.mark.trio
     async def test_add_writer_replace(self, loop, config):
         await self.check_add_replace("writer", loop, config)
-

tests/aiotest/test_callback.py

@@ -2,6 +2,7 @@
 import signal
 import pytest
 
+
 class TestCallback(aiotest.TestCase):
     @pytest.mark.trio
     async def test_call_soon(self, loop):
@@ -49,7 +50,7 @@ def world():
         sync_loop.call_soon(world)
 
         sync_loop.run_forever()
-        if False: # config.stopping:
+        if False:  # config.stopping:
             assert result == ["Hello", "World"]
         else:
             # ensure that world() is not called, since stop() was scheduled
@@ -76,7 +77,7 @@ def test():
         coro = test()
         try:
             # no longer depends on the loop
-            #with pytest.raises(RuntimeError):
+            # with pytest.raises(RuntimeError):
             #    fut = config.asyncio.Future(loop=loop)
             #    await loop.run_future(fut)
             with pytest.raises(RuntimeError, match='not a sync loop'):
@@ -99,4 +100,3 @@ def test():
                 loop.add_signal_handler(signal.SIGTERM, func)
         finally:
             coro.close()
-

tests/aiotest/test_coroutine.py

@@ -1,13 +1,15 @@
 from tests import aiotest
 import pytest
 
+
 async def hello_world(asyncio, result, delay, loop):
     result.append("Hello")
     # retrieve the event loop from the policy
     await asyncio.sleep(delay, loop=loop)
     result.append('World')
     return "."
 
+
 class TestCoroutine(aiotest.TestCase):
     @pytest.mark.trio
     async def test_hello_world(self, loop, config):
@@ -19,7 +21,7 @@ async def test_hello_world(self, loop, config):
     @pytest.mark.trio
     async def run_hello_world(self, loop, config):
         result = []
-        await loop.run_asyncio(hello_world,config.asyncio, result, 0.001, loop)
+        await loop.run_asyncio(hello_world, config.asyncio, result, 0.001, loop)
         assert result == ['Hello', 'World']
 
     @pytest.mark.trio
@@ -37,4 +39,3 @@ async def waiter(asyncio, hello_world, result):
         result = []
         await loop.run_asyncio(waiter, config.asyncio, hello_world, result)
         assert result == ['Future', 'Hello', 'World', '.']
-

tests/aiotest/test_network.py

@@ -1,6 +1,7 @@
 from tests import aiotest
 import pytest
 
+
 def create_classes(config):
     asyncio = config.asyncio
     socket = config.socket
@@ -84,4 +85,3 @@ async def test_tcp_hello(self, loop, config):
         await loop.stop().wait()()
         assert proto.state == 'closed'
         assert proto.received == message
-

tests/aiotest/test_thread.py

@@ -3,20 +3,15 @@
 import trio
 import trio_asyncio
 
-class TestThread(aiotest.TestCase):
-    @classmethod
-    def setUpClass(cls):
-        super(ThreadTests, cls).setUpClass()
-        if not cls.config.support_threads:
-            raise aiotest.unittest.SkipTest("threads are not supported")
 
+class TestThread(aiotest.TestCase):
     @pytest.mark.trio
     async def test_ident(self, loop, config):
         threading = config.threading
         try:
-            get_ident = threading.get_ident   # Python 3
+            get_ident = threading.get_ident  # Python 3
         except AttributeError:
-            get_ident = threading._get_ident   # Python 2
+            get_ident = threading._get_ident  # Python 2
 
         result = {'ident': None}
 
@@ -50,7 +45,7 @@ def work():
     @pytest.mark.trio
     async def test_policy(self, loop, config):
         asyncio = config.asyncio
-        result = {'loop': 'not set'}   # sentinel, different than None
+        result = {'loop': 'not set'}  # sentinel, different than None
 
         def work():
             try:
@@ -65,7 +60,6 @@ def work():
 
     @pytest.mark.trio
     async def test_run_in_thread(self, config):
-        asyncio = config.asyncio
         threading = config.threading
 
         class LoopThread(threading.Thread):
@@ -105,4 +99,3 @@ def func(loop):
         # wait for the other thread's event loop to terminate
         thread.join()
         assert result == [tid]
-

tests/aiotest/test_timer.py

@@ -3,6 +3,7 @@
 import pytest
 import trio
 
+
 class TestTimer(aiotest.TestCase):
     @pytest.mark.trio
     async def test_display_date(self, loop):
@@ -44,4 +45,3 @@ def world(loop):
 
         await loop.wait_stopped()
         assert result == ["Hello", "World"]
-

tests/conftest.py

@@ -9,6 +9,7 @@
 import asyncio
 import trio_asyncio
 
+
 @pytest.fixture
 async def loop():
     async with trio_asyncio.open_loop() as loop:
@@ -17,6 +18,7 @@ async def loop():
         finally:
             await loop.stop().wait()
 
+
 @pytest.fixture
 def sync_loop():
     loop = asyncio.new_event_loop()

tests/interop/test_adapter.py

@@ -4,9 +4,11 @@
 import trio
 from tests import aiotest
 
+
 class SomeThing:
     flag = 0
-    def __init__(self,loop):
+
+    def __init__(self, loop):
         self.loop = loop
 
     @aio2trio
@@ -38,4 +40,3 @@ async def test_trio_asyncio(self, loop):
         res = await sth.dly_asyncio()
         assert res == 4
         assert sth.flag == 1
-