Unpin and upgrade pytest & co

examples/13-hooks/example.py

@@ -55,7 +55,6 @@ async def login_fn(**kwargs):
         insecure=config.cluster.get('insecure-skip-tls-verify'),
         username=config.user.get('username'),
         password=config.user.get('password'),
-        scheme='Bearer',
         token=config.user.get('token'),
         certificate_path=cert.filename() if cert else None,  # can be a temporary file
         private_key_path=pkey.filename() if pkey else None,  # can be a temporary file

requirements.txt

@@ -4,10 +4,10 @@
 # Everything needed to develop (test, debug) the framework.
 coverage
 pytest-aiohttp
-pytest-asyncio==0.10.0  # until fixed: https://github.com/pytest-dev/pytest-asyncio/issues/154
+pytest-asyncio
 pytest-mock
 pytest-cov
-pytest==5.3.5  # until fixed: https://github.com/pytest-dev/pytest-asyncio/issues/154
+pytest>=6.0.0
 aresponses
 asynctest
 freezegun

tests/conftest.py

@@ -578,7 +578,7 @@ def assert_logs_fn(patterns, prohibited=[], strict=False):
 # Helpers for asyncio checks.
 #
 @pytest.fixture(autouse=True)
-def _no_asyncio_pending_tasks():
+def _no_asyncio_pending_tasks(event_loop):
     """
     Ensure there are no unattended asyncio tasks after the test.
 
@@ -592,9 +592,18 @@ def _no_asyncio_pending_tasks():
     collection after every test, and check messages from `asyncio.Task.__del__`.
     This, however, requires intercepting all event-loop creation in the code.
     """
+
     # See `asyncio.all_tasks()` implementation for reference.
     before = {t for t in list(asyncio.tasks._all_tasks) if not t.done()}
+
+    # Run the test.
     yield
+
+    # Let the pytest-asyncio's async2sync wrapper to finish all callbacks. Otherwise, it raises:
+    #   <Task pending name='Task-2' coro=<<async_generator_athrow without __name__>()>>
+    event_loop.run_until_complete(asyncio.sleep(0))
+
+    # Detect all leftover tasks.
     after = {t for t in list(asyncio.tasks._all_tasks) if not t.done()}
     remains = after - before
     if remains: