Trying again for asyncio on windows on py38

Author: altendky

pytest_twisted.py

@@ -1,5 +1,6 @@
 import functools
 import inspect
+import sys
 import warnings
 
 import decorator
@@ -326,3 +327,17 @@ def pytest_configure(config):
     )(blockon)
 
     reactor_installers[config.getoption("reactor")]()
+
+
+def use_asyncio_selector_if_required(config):
+    # https://twistedmatrix.com/trac/ticket/9766
+
+    if (
+        config.getoption("reactor", "default") == "asyncio"
+        and sys.platform == 'win32'
+        and sys.version_info >= (3, 8)
+    ):
+        import asyncio
+
+        selector_policy = asyncio.WindowsSelectorEventLoopPolicy()
+        asyncio.set_event_loop_policy(selector_policy)

testing/conftest.py

@@ -1,20 +1,10 @@
-import sys
-
 import pytest
+import pytest_twisted
 
 
 pytest_plugins = "_pytest.pytester"
 
 
 @pytest.hookimpl(tryfirst=True)
 def pytest_configure(config):
-    if (
-            config.getoption("reactor") == 'asyncio'
-            and sys.platform == 'win32'
-            and sys.version_info >= (3, 8)
-    ):
-        # https://twistedmatrix.com/trac/ticket/9766
-        import asyncio
-
-        selector_policy = asyncio.WindowsSelectorEventLoopPolicy()
-        asyncio.set_event_loop_policy(selector_policy)
+    pytest_twisted.use_asyncio_selector_if_required(config=config)

testing/test_basic.py

@@ -49,6 +49,19 @@ def format_run_result_output_for_assert(run_result):
     )
 
 
+@pytest.fixture(name="default_conftest", autouse=True)
+def _default_conftest(testdir):
+    testdir.makeconftest(textwrap.dedent("""
+    import pytest
+    import pytest_twisted
+
+
+    @pytest.hookimpl(tryfirst=True)
+    def pytest_configure(config):
+        pytest_twisted.use_asyncio_selector_if_required(config=config)
+    """))
+
+
 def skip_if_reactor_not(request, expected_reactor):
     actual_reactor = request.config.getoption("reactor", "default")
     if actual_reactor != expected_reactor:
@@ -627,10 +640,14 @@ def main():
 def test_blockon_in_hook_with_asyncio(testdir, cmd_opts, request):
     skip_if_reactor_not(request, "asyncio")
     conftest_file = """
+    import pytest
     import pytest_twisted as pt
     from twisted.internet import defer
 
+    @pytest.hookimpl(tryfirst=True)
     def pytest_configure(config):
+        pt.use_asyncio_selector_if_required(config=config)
+
         pt.init_asyncio_reactor()
         d = defer.Deferred()
 
@@ -656,6 +673,14 @@ def test_succeed():
 def test_wrong_reactor_with_asyncio(testdir, cmd_opts, request):
     skip_if_reactor_not(request, "asyncio")
     conftest_file = """
+    import pytest
+    import pytest_twisted
+    
+    
+    @pytest.hookimpl(tryfirst=True)
+    def pytest_configure(config):
+        pytest_twisted.use_asyncio_selector_if_required(config=config)
+
     def pytest_addhooks():
         import twisted.internet.default
         twisted.internet.default.install()