flake8'd

Author: smurfix

setup.py

@@ -74,7 +74,7 @@
     # This means, just install *everything* you see under trio/, even if it
     # doesn't look like a source file, so long as it appears in MANIFEST.in:
     include_package_data=True,
-    python_requires=">=3.5.2", # temporary, for RTD
+    python_requires=">=3.5.2",  # temporary, for RTD
     keywords=["async", "io", "trio", "asyncio", "trio-asyncio"],
     setup_requires=['pytest-runner'],
     tests_require=['pytest', 'outcome'],

tests/aiotest/__init__.py

@@ -1,5 +1,4 @@
 import socket
-import sys
 import threading
 import time
 

tests/conftest.py

@@ -7,7 +7,6 @@
 import pytest
 import asyncio
 import trio_asyncio
-import trio_asyncio.loop as loop_
 import inspect
 from async_generator import async_generator, yield_
 

tests/interop/test_adapter.py

@@ -119,7 +119,7 @@ async def test_asyncio_trio_adapted(self, loop):
         assert sth.flag == 2
 
     @pytest.mark.trio
-    async def test_asyncio_trio_depr(self, loop):
+    async def test_asyncio_trio_depr2(self, loop):
         """Call asyncio from trio"""
 
         sth = SomeThing(loop)

tests/interop/test_calls.py

@@ -116,7 +116,7 @@ async def dly_trio(seen):
         assert seen.flag == 2
 
     @pytest.mark.trio
-    async def test_asyncio_trio(self, loop):
+    async def test_asyncio_trio_depr(self, loop):
         """Call asyncio from trio"""
 
         async def dly_trio(seen):
@@ -133,6 +133,7 @@ async def dly_trio(seen):
     async def test_call_asyncio_ctx(self, loop):
         self.did_it = 0
         async with aio_as_trio(AioContext(self, loop), loop=loop) as ctx:
+            assert ctx.parent is self
             assert self.did_it == 2
             self.did_it = 3
         assert self.did_it == 4
@@ -142,6 +143,7 @@ async def test_call_trio_ctx(self, loop):
         async def _call_trio_ctx():
             self.did_it = 0
             async with trio_as_aio(TrioContext(self)) as ctx:
+                assert ctx.parent is self
                 assert self.did_it == 2
                 self.did_it = 3
             assert self.did_it == 4
@@ -153,6 +155,7 @@ async def test_call_trio_ctx_depr(self, loop):
         async def _call_trio_ctx():
             self.did_it = 0
             async with loop.wrap_trio_context(TrioContext(self)) as ctx:
+                assert ctx.parent is self
                 assert self.did_it == 2
                 self.did_it = 3
             assert self.did_it == 4

tests/python/test_events.py

@@ -13,7 +13,6 @@
     import ssl
 except ImportError:
     ssl = None
-import subprocess
 import sys
 import threading
 import errno
@@ -28,7 +27,6 @@
 from asyncio import coroutines
 from asyncio import proactor_events
 from asyncio import selector_events
-from asyncio import sslproto
 from .. import utils as test_utils
 try:
     from test import support

tests/python/test_windows_utils.py

@@ -4,7 +4,6 @@
 import sys
 import unittest
 import warnings
-from unittest import mock
 
 if sys.platform != 'win32':
     raise unittest.SkipTest('Windows only')

tests/test_aio_subprocess.py

@@ -1,13 +1,11 @@
 """Tests for events.py."""
 import pytest
 
-import collections.abc
 import functools
 import os
 import signal
 import subprocess
 import sys
-import errno
 import unittest
 
 import asyncio

tests/test_sync.py

@@ -1,4 +1,3 @@
-import pytest
 import asyncio
 
 

trio_asyncio/adapter.py

@@ -4,7 +4,6 @@
 import types
 import warnings
 
-from async_generator import isasyncgenfunction
 import asyncio
 import trio_asyncio
 from contextvars import ContextVar
@@ -246,7 +245,7 @@ def _allow_asyncio(fn, *args):
             return e.value
         try:
             if isinstance(yielded, asyncio.Future):
-                next_send = yield from trio_asyncio.run_aio_future(yielded)
+                next_send = yield from run_aio_future(yielded)
             else:
                 next_send = yield yielded
         except BaseException as exc: