mirror of
https://github.com/BerriAI/litellm.git
synced 2026-09-13 23:11:40 +00:00
b0626cad8c
APScheduler anchors an interval job at now + interval, so every scheduled background job registered in one proxy startup shares a single firing instant for the life of the process, and every replica a rollout brought up together shares that instant too. Each tick the spend flushes, budget reset sweep, config-in-DB reload, credential reload and cost pollers all hit Postgres at the same moment, on every pod, competing with request-path auth and budget queries. Shift each eligible job by a deterministic offset derived from sha256(job_id, identity), where identity covers the pod and the worker process. The offset lives in the trigger rather than in a one-off next_run_time, because a cron trigger recomputes each fire from the wall clock and would otherwise snap straight back onto the shared instant. An interval job is never offset by more than one of its own periods. Only schedules LiteLLM chose are shifted: interval jobs always, cron jobs only when the id is one of the product's own defaults, so an operator-supplied crontab keeps the instant it asks for. general_settings.scheduled_job_stagger turns it off, widens the window, replaces the identity, or pins a job. The applied offsets are logged once at startup and each fire logs its scheduled instant against its actual start. Resolves LIT-5433 |
||
|---|---|---|
| .. | ||
| html_forms | ||
| test_auth_cache_invalidation_pubsub.py | ||
| test_cache_codec.py | ||
| test_callback_utils.py | ||
| test_config_sync_pubsub.py | ||
| test_custom_openapi_spec.py | ||
| test_encrypt_decrypt_utils.py | ||
| test_expired_ui_session_key_cleanup_manager.py | ||
| test_get_routes.py | ||
| test_http_parsing_utils.py | ||
| test_json_merge_patch.py | ||
| test_key_rotation_e2e.py | ||
| test_key_rotation_integration.py | ||
| test_key_rotation_lock.py | ||
| test_key_rotation_manager.py | ||
| test_load_config_utils.py | ||
| test_openai_endpoint_utils.py | ||
| test_path_utils.py | ||
| test_periodic_reload_schedule.py | ||
| test_reset_budget_job.py | ||
| test_scheduled_job_stagger.py | ||
| test_sse_keepalive.py | ||
| test_static_asset_utils.py | ||
| test_timezone_utils.py | ||
| test_upsert_budget_membership.py | ||
| test_user_api_key_cache.py | ||