mirror of
https://github.com/BerriAI/litellm.git
synced 2026-09-11 22:51:28 +00:00
b544023923
`acquire_lock` caught exceptions to tell a failed attempt from losing the election, but an outage does not always raise. `RedisCache.async_set_cache` catches connection errors, records a swallowed-failure marker and returns None, and None is also how redis reports SET NX losing the race. Both arrived as `not_acquired`, so a Redis outage was published as ordinary contention: the distinction the split was added to make, lost in the most important case. The marker is the only thing that separates them, so it is compared across the attempt. It is a per-task ContextVar, so a concurrent caller's failure cannot be misread as this one's. `swallowed_redis_failure_count` exposes it rather than having callers reach for the private ContextVar. Verified against a stub that mimics RedisCache exactly: an outage now records error, losing the race still records not_acquired, and success still records acquired. |
||
|---|---|---|
| .. | ||
| db_transaction_queue | ||
| mcp_server | ||
| conftest.py | ||
| test_autorouter_session_rollup.py | ||
| test_check_migration.py | ||
| test_create_views.py | ||
| test_daily_spend_bulk_upsert.py | ||
| test_db_pool_metrics.py | ||
| test_db_spend_update_writer.py | ||
| test_db_url_settings.py | ||
| test_exception_handler.py | ||
| test_exception_handler_reconnect_retry.py | ||
| test_gateway_request_tracking.py | ||
| test_log_db_metrics.py | ||
| test_prisma_client.py | ||
| test_prisma_planned_engine_restart.py | ||
| test_prisma_self_heal.py | ||
| test_proxy_worker_heartbeat.py | ||
| test_query_engine_reaper.py | ||
| test_rds_iam_token_expiry.py | ||
| test_replica_identity.py | ||
| test_routing_prisma_wrapper.py | ||
| test_spend_log_batching.py | ||
| test_spend_log_tool_index.py | ||
| test_tool_registry_writer.py | ||