Improve flakiness of persistent connection provider tests:

- Clear caches before each persistent cxn provider test to help
  ensure a clean state for each test.

Author: fselmo

tests/integration/conftest.py

@@ -64,3 +64,14 @@ def event_loop():
     loop = asyncio.get_event_loop_policy().new_event_loop()
     yield loop
     loop.close()
+
+
+@pytest.fixture(autouse=True)
+def _async_test_setup(request) -> None:
+    # Check if the 'async_w3' fixture is available in the current context
+    if "async_w3" in request.fixturenames:
+        async_w3 = request.getfixturevalue("async_w3")
+        if hasattr(async_w3.provider, "_request_processor"):
+            # Clear the request processor cache for persistent connection provider tests
+            async_w3.provider._request_processor.clear_caches()
+    yield

web3/_utils/module_testing/persistent_connection_provider.py

@@ -363,40 +363,11 @@ async def test_async_extradata_poa_middleware_on_eth_subscription(
         # clean up
         async_w3.middleware_onion.remove("poa_middleware")
 
-    @pytest.mark.asyncio
-    async def test_public_socket_api(self, async_w3: "AsyncWeb3") -> None:
-        async_w3.provider._request_processor.clear_caches()
-
-        # send a request over the socket
-        await async_w3.socket.send(
-            RPCEndpoint("eth_getBlockByNumber"), ["latest", True]
-        )
-
-        # recv and validate the unprocessed response
-        response = await async_w3.socket.recv()
-        assert "id" in response, "Expected 'id' key in response."
-        assert "jsonrpc" in response, "Expected 'jsonrpc' key in response."
-        assert "result" in response, "Expected 'result' key in response."
-        assert all(k in response["result"].keys() for k in SOME_BLOCK_KEYS)
-        assert not isinstance(response["result"]["number"], int)  # assert not processed
-
-        # make a request over the socket
-        response = await async_w3.socket.make_request(
-            RPCEndpoint("eth_getBlockByNumber"), ["latest", True]
-        )
-        assert "id" in response, "Expected 'id' key in response."
-        assert "jsonrpc" in response, "Expected 'jsonrpc' key in response."
-        assert "result" in response, "Expected 'result' key in response."
-        assert all(k in response["result"].keys() for k in SOME_BLOCK_KEYS)
-        assert not isinstance(response["result"]["number"], int)  # assert not processed
-
     @pytest.mark.asyncio
     async def test_asyncio_gather_for_multiple_requests_matches_the_responses(
         self,
         async_w3: "AsyncWeb3",
     ) -> None:
-        async_w3.provider._request_processor.clear_caches()
-
         (
             latest,
             chain_id,
@@ -427,3 +398,28 @@ async def test_asyncio_gather_for_multiple_requests_matches_the_responses(
         assert isinstance(chain_id, int)
         assert isinstance(chain_id2, int)
         assert isinstance(chain_id3, int)
+
+    @pytest.mark.asyncio
+    async def test_public_socket_api(self, async_w3: "AsyncWeb3") -> None:
+        # send a request over the socket
+        await async_w3.socket.send(
+            RPCEndpoint("eth_getBlockByNumber"), ["latest", True]
+        )
+
+        # recv and validate the unprocessed response
+        response = await async_w3.socket.recv()
+        assert "id" in response, "Expected 'id' key in response."
+        assert "jsonrpc" in response, "Expected 'jsonrpc' key in response."
+        assert "result" in response, "Expected 'result' key in response."
+        assert all(k in response["result"].keys() for k in SOME_BLOCK_KEYS)
+        assert not isinstance(response["result"]["number"], int)  # assert not processed
+
+        # make a request over the socket
+        response = await async_w3.socket.make_request(
+            RPCEndpoint("eth_getBlockByNumber"), ["latest", True]
+        )
+        assert "id" in response, "Expected 'id' key in response."
+        assert "jsonrpc" in response, "Expected 'jsonrpc' key in response."
+        assert "result" in response, "Expected 'result' key in response."
+        assert all(k in response["result"].keys() for k in SOME_BLOCK_KEYS)
+        assert not isinstance(response["result"]["number"], int)  # assert not processed