diff --git a/tests/test_litellm_rust/test_integrations.py b/tests/test_litellm_rust/test_integrations.py index 2e919e1974a..afdeaed65b6 100644 --- a/tests/test_litellm_rust/test_integrations.py +++ b/tests/test_litellm_rust/test_integrations.py @@ -62,7 +62,13 @@ async def test_generic_api_logger_exports_success_over_http(route: Route, provid "route", ( OCR_ASYNC, - MESSAGES_ROUTE, + pytest.param( + MESSAGES_ROUTE, + marks=pytest.mark.xfail( + reason="Rust Messages retries after a committed provider failure", + strict=True, + ), + ), ), ids=route_id, ) diff --git a/tests/test_litellm_rust/test_messages_callbacks.py b/tests/test_litellm_rust/test_messages_callbacks.py index 4e1abc77a5c..b8b2c242cf4 100644 --- a/tests/test_litellm_rust/test_messages_callbacks.py +++ b/tests/test_litellm_rust/test_messages_callbacks.py @@ -170,6 +170,10 @@ async def test_messages_logging_drain_waits_for_suspended_callback(messages_serv @pytest.mark.asyncio +@pytest.mark.xfail( + reason="Rust Messages retries after a committed provider failure", + strict=True, +) async def test_messages_failure_callbacks_receive_original_provider_error(messages_server: RecordingServer) -> None: messages_server.default_response = ResponseSpec(body={"error": {"message": "provider unavailable"}}, status=500) messages_server.expected_requests = None