Improve integration test robustness and fix asyncio warnings

- Add pytest-dependency and pytest-order for explicit test ordering
- Add wait_for_condition async helper to reduce polling boilerplate
- Add workflow_state fixture to share IDs between dependent tests
- Add cleanup_on_failure fixture to clean branch on test failure
- Fix authentication by adding API token to execute_command
- Move asyncio marker from class level to individual async tests
- Improve assertion messages with detailed context
- Extract timeout/polling values into named constants

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <noreply@anthropic.com>

Author: petercrocker

pyproject.toml

@@ -15,6 +15,8 @@ dependencies = [
     "mypy>=1.15.0",
     "pytest>=8.3.5,<9.0.0",
     "pytest-asyncio>=0.26.0",
+    "pytest-dependency>=0.6.0",
+    "pytest-order>=1.3.0",
     "rich>=13.9.4",
     "ruff>=0.14.1",
     "types-pyyaml>=6.0.12.20250809",
@@ -42,7 +44,7 @@ follow_untyped_imports = true
 [tool.pytest.ini_options]
 asyncio_mode = "auto"
 testpaths = ["tests"]
-asyncio_default_fixture_loop_scope = "function"
+asyncio_default_fixture_loop_scope = "class"
 filterwarnings = [
     "ignore:`background_execution` is deprecated:DeprecationWarning:infrahub_sdk.branch",
 ]

tests/integration/conftest.py

@@ -2,10 +2,12 @@
 
 import os
 import subprocess
+from collections.abc import Generator
 from pathlib import Path
 
 import pytest
 from infrahub_sdk import Config, InfrahubClient, InfrahubClientSync
+from infrahub_testcontainers.container import PROJECT_ENV_VARIABLES
 from infrahub_testcontainers.helpers import TestInfrahubDocker
 
 TEST_DIRECTORY = Path(__file__).parent
@@ -16,28 +18,48 @@ class TestInfrahubDockerWithClient(TestInfrahubDocker):
     """Base test class with Infrahub Docker container and clients."""
 
     @pytest.fixture(scope="class")
-    def async_client_main(self, infrahub_port: int) -> InfrahubClient:
-        """Async Infrahub client on main branch."""
+    def async_client_main(
+        self, infrahub_port: int
+    ) -> Generator[InfrahubClient, None, None]:
+        """Async Infrahub client on main branch.
+
+        Yields:
+            InfrahubClient configured for the test container.
+        """
         client = InfrahubClient(
             config=Config(
                 address=f"http://localhost:{infrahub_port}",
             )
         )
-        return client
+        yield client
 
     @pytest.fixture(scope="class")
-    def client_main(self, infrahub_port: int) -> InfrahubClientSync:
-        """Sync Infrahub client on main branch."""
+    def client_main(
+        self, infrahub_port: int
+    ) -> Generator[InfrahubClientSync, None, None]:
+        """Sync Infrahub client on main branch.
+
+        Yields:
+            InfrahubClientSync configured for the test container.
+        """
         client = InfrahubClientSync(
             config=Config(
                 address=f"http://localhost:{infrahub_port}",
             )
         )
-        return client
+        yield client
 
     @pytest.fixture(scope="class")
-    def client(self, infrahub_port: int, default_branch: str) -> InfrahubClientSync:
-        """Sync Infrahub client on the default test branch."""
+    def client(
+        self, infrahub_port: int, default_branch: str
+    ) -> Generator[InfrahubClientSync, None, None]:
+        """Sync Infrahub client on the default test branch.
+
+        Creates the branch if it doesn't exist and sets it as default.
+
+        Yields:
+            InfrahubClientSync configured for the test branch.
+        """
         client = InfrahubClientSync(
             config=Config(
                 address=f"http://localhost:{infrahub_port}",
@@ -48,13 +70,26 @@ def client(self, infrahub_port: int, default_branch: str) -> InfrahubClientSync:
         if client.default_branch != default_branch:
             client.default_branch = default_branch
 
-        return client
+        yield client
 
     @staticmethod
-    def execute_command(command: str, address: str) -> subprocess.CompletedProcess[str]:
-        """Execute a shell command with Infrahub environment variables."""
+    def execute_command(
+        command: str, address: str
+    ) -> subprocess.CompletedProcess[str]:
+        """Execute a shell command with Infrahub environment variables.
+
+        Args:
+            command: The shell command to execute.
+            address: The Infrahub server address.
+
+        Returns:
+            CompletedProcess with stdout, stderr, and returncode.
+        """
         env = os.environ.copy()
         env["INFRAHUB_ADDRESS"] = address
+        env["INFRAHUB_API_TOKEN"] = PROJECT_ENV_VARIABLES[
+            "INFRAHUB_TESTING_INITIAL_ADMIN_TOKEN"
+        ]
         env["INFRAHUB_MAX_CONCURRENT_EXECUTION"] = "10"
 
         result = subprocess.run(