YAPF'd and flake8'd

Author: smurfix

tests/python/test_events.py

@@ -599,7 +599,7 @@ def test_create_connection_sock(self):
                     sock = socket.socket(family=family, type=type, proto=proto)
                     sock.setblocking(False)
                     self.loop.run_until_complete(self.loop.sock_connect(sock, address))
-                except:
+                except Exception:
                     pass
                 else:
                     break
@@ -1369,7 +1369,7 @@ def test_create_datagram_endpoint_sock(self):
                 sock = socket.socket(family=family, type=type, proto=proto)
                 sock.setblocking(False)
                 sock.bind(address)
-            except:
+            except Exception:
                 pass
             else:
                 break

tests/python/test_selector_events.py

@@ -40,7 +40,7 @@ def _close_self_pipe(self):
         pass
 
 
-def list_to_buffer(l=()):
+def list_to_buffer(l=()):  # noqa: E741
     return bytearray().join(l)
 
 

tests/utils.py

@@ -525,12 +525,12 @@ def new_test_loop(self, gen=None):
         return loop
 
     def setUp(self):
-        #self._get_running_loop = events._get_running_loop
-        #events._get_running_loop = lambda: None
+        # self._get_running_loop = events._get_running_loop
+        # events._get_running_loop = lambda: None
         self._thread_cleanup = support.threading_setup()
 
     def tearDown(self):
-        #events._get_running_loop = self._get_running_loop
+        # events._get_running_loop = self._get_running_loop
 
         events.set_event_loop(None)
 

trio_asyncio/async_.py

@@ -107,7 +107,7 @@ def _main_loop_exit(self):
     from .loop import current_loop, current_policy, TrioPolicy
 
     async with trio.open_nursery() as nursery:
-        policy = current_policy.get() 
+        policy = current_policy.get()
         if not isinstance(policy, TrioPolicy):
             policy = TrioPolicy()
         old_policy = current_policy.set(policy)
@@ -128,4 +128,3 @@ def _main_loop_exit(self):
                 nursery.cancel_scope.cancel()
                 current_loop.reset(old_loop)
                 current_policy.reset(old_policy)
-

trio_asyncio/loop.py

@@ -34,6 +34,7 @@
 current_loop = ContextVar('trio_aio_loop', default=None)
 current_policy = ContextVar('trio_aio_policy', default=None)
 
+
 class _TrioPolicy(asyncio.events.BaseDefaultEventLoopPolicy):
     _loop_factory = TrioEventLoop