6e70c279f8
* fix(router): use cacheable prefix for prompt caching cache keys Fix issue where requests with same cacheable prefix but different user messages were routing to different deployments, preventing cached token reuse. The cache key now correctly includes only the cacheable prefix (up to and including the last cache_control block) instead of the entire messages array. ## New Functions ### extract_cacheable_prefix() Static method that extracts the cacheable prefix from messages for prompt caching. The cacheable prefix is defined as everything UP TO AND INCLUDING the LAST content block (across all messages) that has cache_control with type "ephemeral". This includes ALL blocks before the last cacheable block (even if they don't have cache_control themselves). - Finds the last content block with cache_control across all messages - Returns all messages and content blocks up to and including that last cacheable block - Excludes everything after the last cacheable block (including user messages that come after) - Returns empty list if no cacheable blocks are found ## Changed Functions ### get_prompt_caching_cache_key() Modified to use the cacheable prefix instead of the full messages array when generating cache keys. This ensures that requests with the same cacheable prefix but different user messages generate the same cache key, enabling proper routing to the same deployment. - Now calls extract_cacheable_prefix() to get only cacheable content - Returns None if no cacheable prefix is found (can't generate key) - Cache key is now based on cacheable prefix only, not full messages ### async_get_model_id() Completely refactored to use the cacheable prefix directly instead of the previous workaround that checked progressively shorter message slices. The previous implementation was inefficient and unreliable. - Removed progressive message slicing logic (messages[:-1], messages[:-2], etc.) - Now uses single direct cache lookup with cacheable prefix-based key - More efficient (1 lookup instead of up to 4) - More reliable (uses correct cache key based on cacheable prefix) - Returns None if no cacheable prefix found ### add_model_id() Added None check for cache_key to prevent caching when no cacheable prefix is found. This ensures we don't attempt to cache when there's no meaningful cache key to use. - Added guard: returns early if cache_key is None - Prevents attempting to cache when no cacheable prefix exists ### async_add_model_id() Added None check for cache_key to prevent caching when no cacheable prefix is found. Matches the behavior of add_model_id() for consistency. - Added guard: returns early if cache_key is None - Prevents attempting to cache when no cacheable prefix exists ### get_model_id() Added None check for cache_key to handle cases where no cacheable prefix is found. Ensures consistent behavior across all cache methods. - Added guard: returns None if cache_key is None - Prevents calling get_cache() with None key ## Test ### test_router_prompt_caching_same_cacheable_prefix_routes_to_same_deployment() New end-to-end test that validates the fix. Tests that requests with the same cacheable prefix (system blocks with cache_control) but different user messages: 1. Generate the same cache key 2. Successfully perform cache lookup 3. Route to the same deployment This test reproduces the exact scenario from the user's bug report where three requests with different user messages should route to the same deployment but were previously routing to different ones. Fixes issue where cached tokens couldn't be reused because requests were routed to different providers due to different cache keys. * fix(router): use cast() for proper type handling in extract_cacheable_prefix Replace type annotation with type: ignore comment with proper cast() from typing module, matching the pattern used throughout the codebase for creating modified AllMessageValues dictionaries. |
||
|---|---|---|
| .. | ||
| audio_tests | ||
| basic_proxy_startup_tests | ||
| batches_tests | ||
| code_coverage_tests | ||
| documentation_tests | ||
| enterprise | ||
| guardrails_tests | ||
| image_gen_tests | ||
| litellm/llms | ||
| litellm_utils_tests | ||
| litellm-proxy-extras | ||
| llm_responses_api_testing | ||
| llm_translation | ||
| load_tests | ||
| local_testing | ||
| logging_callback_tests | ||
| mcp_tests | ||
| multi_instance_e2e_tests | ||
| ocr_tests | ||
| old_proxy_tests/tests | ||
| openai_endpoints_tests | ||
| otel_tests | ||
| pass_through_tests | ||
| pass_through_unit_tests | ||
| proxy_admin_ui_tests | ||
| proxy_security_tests | ||
| proxy_unit_tests | ||
| router_unit_tests | ||
| scim_tests | ||
| search_tests | ||
| spend_tracking_tests | ||
| store_model_in_db_tests | ||
| test_litellm | ||
| unified_google_tests | ||
| vector_store_tests | ||
| windows_tests | ||
| __init__.py | ||
| gettysburg.wav | ||
| large_text.py | ||
| openai_batch_completions.jsonl | ||
| README.MD | ||
| test_budget_management.py | ||
| test_callbacks_on_proxy.py | ||
| test_config.py | ||
| test_debug_warning.py | ||
| test_end_users.py | ||
| test_entrypoint.py | ||
| test_fallbacks.py | ||
| test_gpt5_azure_temperature_support.py | ||
| test_health.py | ||
| test_keys.py | ||
| test_litellm_proxy_responses_config.py | ||
| test_logging.conf | ||
| test_models.py | ||
| test_openai_endpoints.py | ||
| test_organizations.py | ||
| test_passthrough_endpoints.py | ||
| test_ratelimit.py | ||
| test_resource_cleanup.py | ||
| test_spend_logs.py | ||
| test_team_logging.py | ||
| test_team_members.py | ||
| test_team.py | ||
| test_users.py | ||
In total litellm runs 1000+ tests
[02/20/2025] Update:
To make it easier to contribute and map what behavior is tested,
we've started mapping the litellm directory in tests/test_litellm
This folder can only run mock tests.