Work on

pytest_asyncio/_runner.py

@@ -22,8 +22,8 @@ def install(
     ) -> None:
         node = request.node
         print("\n+++++++++", id(node))
-        if hasattr(request, "param"):
-            print("@@@@@@@@@", request.param)
+        #        if hasattr(request, "param"):
+        #            print("@@@@@@@@@", request.param)
         runner = getattr(node, "_asyncio_runner", None)
         if runner is None:
             runner = cls(node, loop)
@@ -32,7 +32,14 @@ def install(
             # parametrized non-function scope loop was recalculated
             # with other params or precessors
             runner._set_loop(loop)
-        request.addfinalizer(runner._uninstall)
+
+    @classmethod
+    def uninstall(cls, request: pytest.FixtureRequest) -> None:
+        node = request.node
+        print("#########", id(node), type(node))
+        runner = getattr(node, "_asyncio_runner", None)
+        assert runner is not None
+        runner._uninstall
 
     @classmethod
     def get(cls, node: pytest.Item) -> "Runner":

pytest_asyncio/plugin.py

@@ -271,13 +271,16 @@ def pytest_fixture_post_finalizer(fixturedef: FixtureDef, request: SubRequest) -
         new_loop = policy.new_event_loop()  # Replace existing event loop
         # Ensure subsequent calls to get_event_loop() succeed
         policy.set_event_loop(new_loop)
+        Runner.uninstall(request)
 
 
 @pytest.hookimpl(hookwrapper=True)
 def pytest_fixture_setup(
     fixturedef: FixtureDef, request: SubRequest
 ) -> Optional[object]:
     """Adjust the event loop policy when an event loop is produced."""
+    if hasattr(request, "param"):
+        print("@@@@@@@@@", fixturedef.argname, request.param)
     if fixturedef.argname == "event_loop":
         # a marker for future runners lookup
         # The lookup doesn't go deeper than a node with this marker set.