mirror of
https://github.com/BerriAI/litellm.git
synced 2026-10-11 03:38:38 +00:00
d16c4dad4b
* feat(logging): add async_post_call_failure_deployment_hook CustomLogger already has async_pre_call_deployment_hook and async_post_call_success_deployment_hook, both firing once per real deployment attempt from wrapper_async since the router re-enters that wrapper fresh on every retry and fallback step. There was no failure-side counterpart; the only failure signal, async_log_failure_event, fires once per logical client request behind a dedup gate, so fallback chain attempts 2+ were invisible to callbacks needing per-deployment-attempt granularity. Adds async_post_call_failure_deployment_hook(request_data, exception, call_type) to CustomLogger and a matching dispatcher in utils.py, called from wrapper_async's except block. It needs no dedup coordination since each real attempt naturally re-enters the wrapper once. Unlike its two siblings, the dispatcher wraps each callback call in its own try/except since it runs on the wrapper's own exception path and a broken callback must never mask the exception about to be re-raised to the caller. * feat(logging): pass fallback_depth through to async_post_call_failure_deployment_hook Router already tracks fallback_depth internally on each fallback hop (litellm/router_utils/fallback_event_handlers.py), incrementing it once per target tried, but nothing surfaced it to CustomLogger callbacks. Reads it off request_data in the dispatcher and passes it through as a best-effort int | None keyword: None on the first, pre-fallback attempt or a bare SDK call with no router, 1 on the first fallback hop, 2 on the second, and so on. Verified live against a real multi-hop Router fallback chain before adding the regression tests. * fix(logging): fire async_post_call_failure_deployment_hook on internal calls too The failure hook was gated behind the same not _is_litellm_internal_call check as the request-level dedup-gated failure logging, so a failed internal sub-call (e.g. an emulated file-search step) never reached it, even though its async_pre_call_deployment_hook and async_post_call_success_deployment_hook siblings already fire unconditionally for such calls. * chore: retrigger CI (lint job hit a transient GitHub Actions infra outage on the prior push) * chore: retrigger CI (lint job hit the same GitHub Actions infra outage again) * fix(logging): scope async_post_call_failure_deployment_hook to the actual model call The hook was dispatched from the wrapper's broad outer except, which also catches BudgetExceededError (raised before any deployment attempt), errors from async_pre_call_deployment_hook, and errors raised after a successful model call (post_call_processing, async_post_call_success_deployment_hook, caching). None of those are a deployment attempt failing, so the hook misreported them as one. Scoped the hook to a try/except around the model call itself, so it only fires when that specific call raises, matching its own documented contract. * test: assert the callback actually ran in the failure-hook error-isolation test An upstream test-quality gate (TQ001) flagged this test for asserting nothing, so it could only fail by raising. Track whether the exploding callback actually ran and assert on it, so the test would catch a dispatcher that silently skipped every callback instead of isolating a raising one. * fix(logging): harden async_post_call_failure_deployment_hook against 5 maintainer-verified issues A maintainer's live-proxy A/B review against base found five real problems with the failure hook, all reproduced and fixed: - The dispatcher called overrides with fallback_depth as a required keyword, so an override matching this PR's own earlier 3-arg proof-of-fix example raised TypeError, swallowed at debug level, on every call. Now checks the override's signature once per class and omits the keyword when unsupported. - A callback mutating the exception it receives (e.g. status_code) changed what the real caller got back, since it was the same live object about to be re-raised. Callbacks now receive a same-class snapshot instead. - request_data exposed attempted_targets, the router's own live fallback-walk bookkeeping shared by reference across every hop, so a callback calling .record() on it could make the router skip a deployment it never actually tried. Now excluded from what the hook receives. - The hook's own await sat directly in the model-call except block, so a caller-side cancellation landing mid-await (e.g. asyncio.wait_for) replaced the real deployment exception with CancelledError/ TimeoutError. Now isolated so hook dispatch can never mask the real failure. - The timestamp used for the reported failure duration was captured after the hook ran, so a slow callback inflated async_log_failure_event's duration. Now captured before the hook dispatches. * fix(logging): preserve traceback/cause/context on the failure-hook exception snapshot Bugbot found a real gap in the previous round's exception-mutation fix: _snapshot_exception_for_hook only copied __dict__ and args, so a callback formatting or inspecting the failure chain saw an empty traceback and lost chained-exception context, even though the live exception still has them. __traceback__/__cause__/__context__ aren't stored in __dict__, so they need copying explicitly. * fix(logging): preserve __suppress_context__ on the failure-hook exception snapshot Setting __cause__ has a documented CPython side effect of implicitly forcing __suppress_context__ to True. Since the previous round's traceback fix set __cause__ before __suppress_context__, a normal implicit-chaining exception (no `raise ... from`, __suppress_context__ naturally False) got its context wrongly suppressed on the snapshot. Now __suppress_context__ is set explicitly, after __cause__, so it always reflects the real exception. * fix(logging): use MappingProxyType for the failure-hook's sanitized request_data A LIT002 budget check (surfaced by rebasing onto a moved base) flagged the dict comprehension building safe_request_data as mutable construction. MappingProxyType is also a strictly better fit here: a genuinely read-only view, not just an immutable-looking dict, matching the intent that callbacks should never be able to mutate what they're handed. --------- Co-authored-by: Deepanshu <deepanshu.lulla@alpha-sense.com> |
||
|---|---|---|
| .. | ||
| a2a_protocol | ||
| anthropic_interface | ||
| batches | ||
| caching | ||
| completion_extras | ||
| compression | ||
| containers | ||
| enterprise | ||
| expected_fine_tuning_api | ||
| expected_responses_api_request | ||
| experimental_mcp_client | ||
| google_genai | ||
| images | ||
| integrations | ||
| interactions | ||
| litellm_core_utils | ||
| llms | ||
| models | ||
| ocr | ||
| passthrough | ||
| proxy | ||
| rag | ||
| realtime_api | ||
| repositories | ||
| rerank_api | ||
| responses | ||
| router_strategy | ||
| router_utils | ||
| rust_bridge | ||
| sandbox | ||
| secret_managers | ||
| test_router | ||
| types | ||
| vector_stores | ||
| videos | ||
| __init__.py | ||
| conftest.py | ||
| log.txt | ||
| readme.md | ||
| test__types.py | ||
| test_a2a_registry_lookup.py | ||
| test_acompletion_session_reuse_e2e.py | ||
| test_add_deployment_no_master_key.py | ||
| test_aembedding_session_reuse_e2e.py | ||
| test_anthropic_beta_headers_filtering.py | ||
| test_anthropic_skills_transformation.py | ||
| test_anthropic_sonnet_1hr_cache_pricing.py | ||
| test_assert_ci_coverage.py | ||
| test_assert_workflow_dir_hygiene.py | ||
| test_audio_transcription_rust_bridge.py | ||
| test_azure_ad_token_credential_resolution.py | ||
| test_azure_ai_grok_4_3_model_metadata.py | ||
| test_azure_audio_price_aliases.py | ||
| test_batch_completion_models_all_responses.py | ||
| test_bedrock_anthropic_1hr_cache_pricing.py | ||
| test_bedrock_batch_pricing.py | ||
| test_bedrock_extended_beta_models.py | ||
| test_bedrock_nemotron_super.py | ||
| test_bedrock_usgov_haiku_1hr_cache.py | ||
| test_bedrock_usgov_pricing.py | ||
| test_budget_ratchet_check.py | ||
| test_chat_ui_responses_session.py | ||
| test_check_licenses.py | ||
| test_check_migrations_no_data_rewrites.py | ||
| test_check_test_quality.py | ||
| test_check_type_discipline.py | ||
| test_circleci_path_filter.py | ||
| test_circleci_rust_toolchain.py | ||
| test_claude_fable_5_config.py | ||
| test_claude_haiku_4_5_config.py | ||
| test_claude_opus_4_6_config.py | ||
| test_claude_opus_4_8_config.py | ||
| test_claude_opus_5_config.py | ||
| test_claude_sonnet_4_6_config.py | ||
| test_claude_sonnet_5_config.py | ||
| test_cloudflare_workers_ai_model_metadata.py | ||
| test_command_r7b_pricing.py | ||
| test_completion_timeout_resolution.py | ||
| test_component_entrypoint.py | ||
| test_compression.py | ||
| test_conftest.py | ||
| test_conftest_isolation.py | ||
| test_constants.py | ||
| test_container_router.py | ||
| test_cost_calculation_log_level.py | ||
| test_cost_calculator.py | ||
| test_count_tokens_public_api.py | ||
| test_dashscope_image_generation.py | ||
| test_daybreak_model_metadata.py | ||
| test_deepseek_model_metadata.py | ||
| test_detect_changes.py | ||
| test_dockerfile_non_root.py | ||
| test_e2e_egress_sentinel.py | ||
| test_eager_tiktoken_load.py | ||
| test_env_key_doc_gate.py | ||
| test_exception_exports.py | ||
| test_exception_header_preservation.py | ||
| test_exception_mapping_request_attribute.py | ||
| test_filter_out_litellm_params.py | ||
| test_gate_slot_lock.py | ||
| test_gemini_3_1_flash_lite_image_pricing.py | ||
| test_get_blog_posts.py | ||
| test_git_hooks.py | ||
| test_github_close_low_quality_prs.py | ||
| test_github_review_gate.py | ||
| test_github_triage_with_llm.py | ||
| test_github_triage_workflows.py | ||
| test_gpt_5_4_model_metadata.py | ||
| test_gpt_5_5_model_metadata.py | ||
| test_gpt_image_cost_calculator.py | ||
| test_gpt_realtime_mode.py | ||
| test_groq_streaming_encoding.py | ||
| test_guardrail_exception_status_codes.py | ||
| test_lazy_imports.py | ||
| test_litellm_params_reserved_keys.py | ||
| test_logging.py | ||
| test_lowest_latency_zero_tokens.py | ||
| test_main.py | ||
| test_main_module_header.py | ||
| test_mistral_medium_3_5_model_metadata.py | ||
| test_mistral_small_4_0_model_metadata.py | ||
| test_mistral_zai_glm_5_2_model_metadata.py | ||
| test_model_block_unblock.py | ||
| test_model_cost_aliases.py | ||
| test_model_param_helper.py | ||
| test_model_prices_schema.py | ||
| test_model_response_normalization.py | ||
| test_muse_spark_1_1_model_metadata.py | ||
| test_muse_spark_1_2_model_metadata.py | ||
| test_mutation_report.py | ||
| test_nested_drop_params.py | ||
| test_non_chat_routes_open_llm_spans.py | ||
| test_openai_embedding_encoding_format_default.py | ||
| test_pre_commit_lint.py | ||
| test_prisma_generate_if_needed.py | ||
| test_project_alias_tracking.py | ||
| test_project_tags_pydantic.py | ||
| test_proxy_auth.py | ||
| test_rag_openai_ingestion.py | ||
| test_rate_limit_error_unification.py | ||
| test_redact_string_in_error_paths.py | ||
| test_redis.py | ||
| test_register_model_custom_pricing.py | ||
| test_register_model_zero_cost_persistence.py | ||
| test_replicate_model_key_format.py | ||
| test_responses_api_bridge_non_stream.py | ||
| test_responses_id_security.py | ||
| test_responses_streaming_container_ownership.py | ||
| test_retrieve_batch_bedrock_dispatch.py | ||
| test_router.py | ||
| test_router_block_helpers.py | ||
| test_router_exception_redaction.py | ||
| test_router_google_genai.py | ||
| test_router_model_cost_isolation.py | ||
| test_router_order_fallback.py | ||
| test_router_per_deployment_num_retries.py | ||
| test_router_redis_init.py | ||
| test_router_retry_backoff_headers.py | ||
| test_router_retry_non_retryable_errors.py | ||
| test_router_retry_policy_update.py | ||
| test_router_silent_experiment.py | ||
| test_router_streaming_fallback_metadata.py | ||
| test_router_weighted_failover.py | ||
| test_ruff_strict_gate.py | ||
| test_sambanova_model_metadata.py | ||
| test_secret_redaction.py | ||
| test_select_ui_test_scope.py | ||
| test_service_logger.py | ||
| test_setup_wizard.py | ||
| test_shared_session_integration.py | ||
| test_ssl_verify_unit.py | ||
| test_stream_chunk_builder_annotations.py | ||
| test_stream_chunk_builder_images.py | ||
| test_streaming_connection_cleanup.py | ||
| test_system_message_format_bug.py | ||
| test_test_quality_gate.py | ||
| test_thinking_enabled.py | ||
| test_together_ai_model_metadata.py | ||
| test_type_check_gate.py | ||
| test_type_discipline_gate.py | ||
| test_utils.py | ||
| test_utils_module_docstring.py | ||
| test_uuid_helper.py | ||
| test_vcr_safe_body_matcher.py | ||
| test_video_generation.py | ||
| test_with_dashboard_node.py | ||
| test_xai_grok_4_3_model_metadata.py | ||
| test_xai_responses_auto_routing.py | ||
Testing for litellm/
This directory 1:1 maps the the litellm/ directory, and can only contain mocked tests.
The point of this is to:
- Increase test coverage of
litellm/ - Make it easy for contributors to add tests for the
litellm/package and easily run tests without needing LLM API keys.
File name conventions
litellm/proxy/test_caching_routes.pymaps tolitellm/proxy/caching_routes.pytest_<filename>.pymaps tolitellm/<filename>.py