refactor: seperate tests

Author: bright2227

.github/workflows/publish.yml

@@ -44,4 +44,4 @@ jobs:
           TWINE_USERNAME: __token__
           TWINE_PASSWORD: ${{ secrets.PYPI_API_TOKEN }}  #
         run:  |
-          uv run twine upload --verbose --repository testpypi dist/*
+          uv run twine upload --verbose --repository pypi dist/*

tests/__init__.py renamed to tests/e2e/loop/__init__.py

@@ -1,17 +1,26 @@
 import asyncio
+import os
+import tempfile
 from typing import cast
 
 import pytest
+import pytest_asyncio
 
 from uringloop.loop import IouringProactorEventLoop, IouringProactorEventLoopPolicy
 
 
-@pytest.fixture(scope="session", autouse=True)
-def event_loop_policy():
+@pytest_asyncio.fixture(scope="package", autouse=True)
+async def event_loop_policy():
     asyncio.set_event_loop_policy(IouringProactorEventLoopPolicy())
 
+# TODO: remove pytest_asyncio warning
 @pytest.fixture
 def event_loop():
     loop = asyncio.get_event_loop()
     yield cast(IouringProactorEventLoop, loop)
     loop.close()
+
+@pytest.fixture
+def unix_socket_path():
+    with tempfile.TemporaryDirectory() as f:
+        yield os.path.join(f, "test.sock")

tests/conftest.py renamed to tests/e2e/loop/conftest.py

@@ -91,6 +91,19 @@ async def _run_proactor_task():
             await asyncio.sleep(0.1)
 
     task = loop.create_task(_run_proactor_task())
+
+    def stop_all_coro_if_raise_exception(task: asyncio.Task[None]):
+        if task.exception():  # If task failed
+            # Cancel all other tasks
+            for t in asyncio.all_tasks(loop):
+                if t != task and not t.done():
+                    t.cancel()
+
+            loop.run_until_complete(loop.shutdown_asyncgens())
+
+    # Add failure callback
+    task.add_done_callback(stop_all_coro_if_raise_exception)
+
     yield proactor
 
     # Cleanup