Fix tests

Author: WiZeYAR

pyproject.toml

@@ -52,9 +52,10 @@ pex = "*"
 requires = ["poetry-core"]
 build-backend = "poetry.core.masonry.api"
 
-[tool.pytest.ini_options]
-asyncio_mode = "auto"
-asyncio_default_fixture_loop_scope = "function"
-
 [tool.poetry.requires-plugins]
 poetry-plugin-export = ">=1.8"
+
+[tool.pytest.ini_options]
+asyncio_mode = "auto"
+asyncio_default_fixture_loop_scope = "session"
+asyncio_default_test_loop_scope = "session"

tests/core/amqp/conftest.py

@@ -20,5 +20,6 @@
 
 @pytest_asyncio.fixture(scope="function")
 async def amqp_pool(amqp_uri: str) -> AsyncGenerator[AmqpPool, None]:
+    channel_pool.cache_clear()
     pool = channel_pool(amqp_uri)
     yield pool

tests/core/amqp/test_endpoint.py

@@ -136,6 +136,7 @@ def params_2(amqp_pool, correlation_ids):
     return params("app-2", amqp_pool, correlation_ids)
 
 
+@pytest.mark.asyncio
 async def test_queue(params_1: EndpointParams, operation: Operation):
     producer: Sender[Log] = Sender(operation, params_1)
     consumer: Receiver[Log] = Receiver(operation, params_1)