diff --git a/backend/apps/agents/manager/run/lane_preflight.py b/backend/apps/agents/manager/run/lane_preflight.py index e54c6761..98ed66b1 100644 --- a/backend/apps/agents/manager/run/lane_preflight.py +++ b/backend/apps/agents/manager/run/lane_preflight.py @@ -99,8 +99,8 @@ def injected_dead_conn(provider: str) -> Dict: async def dead_connection(provider: str) -> Optional[Dict]: """The provider's connection if the router considers it dead, else None. Never raises: a preflight that cannot read health must let the turn proceed, because guessing "dead" would ground a working lane.""" - from backend.apps.agents.core.fault_injection import armed - if armed("dead_lane"): + from backend.apps.agents.core.fault_injection import armed as p_fault_armed + if p_fault_armed("dead_lane"): logger.warning("[fault] dead_lane armed: reporting %s as a dead credential", provider) return injected_dead_conn(provider) try: diff --git a/backend/tests/test_fault_injection.py b/backend/tests/test_fault_injection.py index ee841316..9ac60fa0 100644 --- a/backend/tests/test_fault_injection.py +++ b/backend/tests/test_fault_injection.py @@ -60,6 +60,7 @@ WIRED_IN = { "auth_401": TURN_RUNNER, "transport_death": TURN_RUNNER, "empty_finish": "backend/apps/agents/manager/streaming/handle_assistant_message.py", + "dead_lane": "backend/apps/agents/manager/run/lane_preflight.py", }