diff --git a/.github/pull_request_template.md b/.github/pull_request_template.md index 99f79c0b272..9658baeb89a 100644 --- a/.github/pull_request_template.md +++ b/.github/pull_request_template.md @@ -4,7 +4,7 @@ ## Linear ticket - + ## Pre-Submission checklist diff --git a/.github/workflows/check-ui-api-types.yml b/.github/workflows/check-ui-api-types.yml index eeb5545b15e..d8053c15683 100644 --- a/.github/workflows/check-ui-api-types.yml +++ b/.github/workflows/check-ui-api-types.yml @@ -54,7 +54,7 @@ jobs: run: uv run --no-sync prisma generate --schema litellm/proxy/schema.prisma - name: Set up Node.js - uses: actions/setup-node@a0853c24544627f65ddf259abe73b1d18a591444 # v5.0 + uses: actions/setup-node@a0853c24544627f65ddf259abe73b1d18a591444 # v5.0.0 with: node-version: "20" cache: "npm" diff --git a/.github/workflows/codeql.yml b/.github/workflows/codeql.yml index babe3b62933..d3a165a11da 100644 --- a/.github/workflows/codeql.yml +++ b/.github/workflows/codeql.yml @@ -43,14 +43,14 @@ jobs: persist-credentials: false - name: Initialize CodeQL - uses: github/codeql-action/init@ebcb5b36ded6beda4ceefea6a8bc4cc885255bb3 # v3 + uses: github/codeql-action/init@ebcb5b36ded6beda4ceefea6a8bc4cc885255bb3 # v3.34.1 with: languages: ${{ matrix.language }} build-mode: ${{ matrix.build-mode }} config-file: ./.github/codeql/codeql-config.yml - name: Perform CodeQL Analysis - uses: github/codeql-action/analyze@ebcb5b36ded6beda4ceefea6a8bc4cc885255bb3 # v3 + uses: github/codeql-action/analyze@ebcb5b36ded6beda4ceefea6a8bc4cc885255bb3 # v3.34.1 with: category: "/language:${{ matrix.language }}" output: sarif-results @@ -77,7 +77,7 @@ jobs: output: sarif-results/python.sarif - name: Upload SARIF - uses: github/codeql-action/upload-sarif@ebcb5b36ded6beda4ceefea6a8bc4cc885255bb3 # v3 + uses: github/codeql-action/upload-sarif@ebcb5b36ded6beda4ceefea6a8bc4cc885255bb3 # v3.34.1 with: sarif_file: sarif-results category: "/language:${{ matrix.language }}" diff --git a/.github/workflows/review_gate.yml b/.github/workflows/review_gate.yml deleted file mode 100644 index ba4b488b79d..00000000000 --- a/.github/workflows/review_gate.yml +++ /dev/null @@ -1,131 +0,0 @@ -name: Agent Shin — review gate - -# Keeps the `ready for review` label in sync with whether an external PR -# currently clears BOTH the LLM rubric AND Greptile's confidence score. -# -# pass -> add `ready for review` + a "passed / all clear" comment -# regress -> remove the label + a "what's missing" comment (PR stays open) -# fail, <24h old -> a one-time "what's missing" notice (grace window) -# fail, >24h old -> close + a comment (reopen via `@agent-shin reconsider`) -# -# DRY-RUN BY DEFAULT. Every side effect (label add/remove, comment, close) is -# gated behind `--close`, which is only added when the repo variable -# `AGENT_SHIN_ENABLED == "true"`. Until then runs only write the verdict to the -# workflow step summary. -# -# Manual single PR: gh workflow run "Agent Shin — review gate" -f pr_number=NNN -# Manual dry-run: gh workflow run "Agent Shin — review gate" -f close=false -# -# We use `pull_request_target` so the workflow can read repo secrets and run -# against fork PRs. Fork code is never checked out — only PR metadata is read -# via `gh api`. - -on: - pull_request_target: - types: [opened, reopened, synchronize, ready_for_review] - schedule: - # Daily at 09:30 UTC — re-reconciles labels as Greptile re-reviews land. - - cron: "30 9 * * *" - workflow_dispatch: - inputs: - pr_number: - description: "Single PR to reconcile (omit to sweep all open PRs)." - required: false - close: - description: "If AGENT_SHIN_ENABLED=true, actually act (false = dry run)." - required: false - default: "false" - type: choice - options: - - "true" - - "false" - grace_days: - description: "Hours/24 a failing, un-tagged PR may stay open before close." - required: false - default: "1" - min_greptile_score: - description: "Greptile score below which a PR counts as not passing (1-5)." - required: false - default: "4" - -permissions: - contents: read - issues: write - pull-requests: write - -jobs: - review-gate: - if: github.repository == 'BerriAI/litellm' - runs-on: ubuntu-latest - steps: - - name: Checkout triage script - uses: actions/checkout@08eba0b27e820071cde6df949e0beb9ba4906955 # v4.3.0 - with: - sparse-checkout: .github/scripts - persist-credentials: false - - - name: Set up Python - uses: actions/setup-python@a26af69be951a213d495a4c3e4e4022e16d87065 # v5.6.0 - with: - python-version: "3.12" - - - name: Install LLM client - run: pip install --no-cache-dir --require-hashes -r .github/scripts/triage-requirements.txt - - - name: Run review gate - env: - GH_TOKEN: ${{ secrets.GITHUB_TOKEN }} - # Mirror the triage workflow: only expose the LLM key when the bot is - # enabled or a collaborator triggers it manually, so an external user - # can't force paid LLM calls by churning a fork PR while the bot is - # still in dry-run. - OPENAI_API_KEY: ${{ (vars.AGENT_SHIN_ENABLED == 'true' || github.event_name == 'workflow_dispatch') && secrets.OPENAI_API_KEY || '' }} - OPENAI_BASE_URL: ${{ vars.OPENAI_BASE_URL }} - TRIAGE_MODEL: ${{ vars.TRIAGE_MODEL }} - AGENT_SHIN_ENABLED: ${{ vars.AGENT_SHIN_ENABLED }} - CLOSE_FLAG: ${{ github.event.inputs.close || 'false' }} - GRACE_DAYS: ${{ github.event.inputs.grace_days || '1' }} - MIN_GREPTILE_SCORE: ${{ github.event.inputs.min_greptile_score || '4' }} - EVENT_PR: ${{ github.event.pull_request.number }} - INPUT_PR: ${{ github.event.inputs.pr_number }} - run: | - set -euo pipefail - COMMON=(--review-gate --grace-days "${GRACE_DAYS}" --min-greptile-score "${MIN_GREPTILE_SCORE}") - - # Fail-safe gating, identical philosophy to the Greptile closer: - # - AGENT_SHIN_ENABLED must be the EXACT string "true" to act at all. - # - A manual dispatch can still preview with close=false. - # - Automatic triggers (PR events, schedule) act once enabled — that - # is the whole point of the gate (re-tag / un-tag automatically). - DO_CLOSE="false" - if [ "${AGENT_SHIN_ENABLED:-false}" != "true" ]; then - echo "::notice::AGENT_SHIN_ENABLED is not 'true' -> dry-run (no labels/comments/closes)." - elif [ "${GITHUB_EVENT_NAME:-}" = "workflow_dispatch" ] && [ "${CLOSE_FLAG:-false}" = "true" ]; then - DO_CLOSE="true" - echo "::notice::Manual run -> acting for real." - elif [ "${GITHUB_EVENT_NAME:-}" != "workflow_dispatch" ]; then - DO_CLOSE="true" - echo "::notice::Enabled automatic trigger (${GITHUB_EVENT_NAME:-}) -> acting for real." - else - echo "::notice::Manual dispatch with close=false -> dry-run." - fi - if [ "${DO_CLOSE}" = "true" ]; then - COMMON+=(--close) - fi - - # Single PR (PR event or explicit input) vs. sweep over all open PRs. - TARGET_PR="${EVENT_PR:-${INPUT_PR:-}}" - if [ -n "${TARGET_PR}" ]; then - python3 .github/scripts/triage_with_llm.py --repo "${{ github.repository }}" --pr "${TARGET_PR}" "${COMMON[@]}" - else - echo "::notice::Sweeping all open PRs." - # Match GH_LIST_ALL_LIMIT in agent_shin_shared.py: gh lists newest-first, - # so any cap below the real backlog silently drops the *oldest* PRs — - # exactly the stale ones this daily sweep is meant to reconcile. - mapfile -t NUMBERS < <(gh pr list --repo "${{ github.repository }}" --state open --limit 100000 --json number --jq '.[].number') - for n in "${NUMBERS[@]}"; do - echo "::group::PR #${n}" - python3 .github/scripts/triage_with_llm.py --repo "${{ github.repository }}" --pr "${n}" "${COMMON[@]}" || echo "::warning::review gate errored on #${n}" - echo "::endgroup::" - done - fi diff --git a/.github/workflows/test-litellm-ui-build.yml b/.github/workflows/test-litellm-ui-build.yml index 68497b10dbb..b83119712a7 100644 --- a/.github/workflows/test-litellm-ui-build.yml +++ b/.github/workflows/test-litellm-ui-build.yml @@ -25,7 +25,7 @@ jobs: persist-credentials: false - name: Setup Node.js - uses: actions/setup-node@a0853c24544627f65ddf259abe73b1d18a591444 # v5.0 + uses: actions/setup-node@a0853c24544627f65ddf259abe73b1d18a591444 # v5.0.0 with: node-version: "20" cache: "npm" @@ -77,7 +77,7 @@ jobs: - name: Setup Node.js if: steps.changed.outputs.has_files == 'true' - uses: actions/setup-node@a0853c24544627f65ddf259abe73b1d18a591444 # v5.0 + uses: actions/setup-node@a0853c24544627f65ddf259abe73b1d18a591444 # v5.0.0 with: node-version: "20" cache: "npm" diff --git a/.github/workflows/test-unit-proxy-endpoints.yml b/.github/workflows/test-unit-proxy-endpoints.yml index 0a9513ec024..d9b6a348b60 100644 --- a/.github/workflows/test-unit-proxy-endpoints.yml +++ b/.github/workflows/test-unit-proxy-endpoints.yml @@ -11,8 +11,6 @@ on: permissions: contents: read - id-token: write - pull-requests: write concurrency: group: ${{ github.workflow }}-${{ github.event.pull_request.number || github.ref }} @@ -20,6 +18,10 @@ concurrency: jobs: proxy-endpoints: + permissions: + contents: read + id-token: write + pull-requests: write uses: ./.github/workflows/_test-unit-base.yml with: test-path: >- @@ -52,6 +54,10 @@ jobs: # is independent and its coverage artifact is uploaded separately. # See: https://www.notion.so/36c43b8acdab81ee845fd5365128a2fc proxy-server: + permissions: + contents: read + id-token: write + pull-requests: write uses: ./.github/workflows/_test-unit-base.yml with: test-path: tests/test_litellm/proxy/proxy_server diff --git a/.github/workflows/test_server_root_path.yml b/.github/workflows/test_server_root_path.yml index 57ff746c9c8..985653796c2 100644 --- a/.github/workflows/test_server_root_path.yml +++ b/.github/workflows/test_server_root_path.yml @@ -32,17 +32,16 @@ jobs: df -h / - name: Set up Docker Buildx - uses: docker/setup-buildx-action@8d2750c68a42422c14e847fe6c8ac0403b4cbd6f # v3.12 + uses: docker/setup-buildx-action@8d2750c68a42422c14e847fe6c8ac0403b4cbd6f # v3.12.0 - name: Build Docker image - uses: docker/build-push-action@0adf9959216b96bec444f325f1e493d4aa344497 #v6.14 + uses: docker/build-push-action@0adf9959216b96bec444f325f1e493d4aa344497 # v6.14.0 with: context: . file: ./docker/Dockerfile.non_root tags: litellm-test:${{ github.sha }} load: true - cache-from: type=gha - cache-to: type=gha,mode=max + push: false - name: Start LiteLLM container with SERVER_ROOT_PATH run: | diff --git a/.github/workflows/triage_pr_with_llm.yml b/.github/workflows/triage_pr_with_llm.yml deleted file mode 100644 index 936547598fb..00000000000 --- a/.github/workflows/triage_pr_with_llm.yml +++ /dev/null @@ -1,110 +0,0 @@ -name: Agent Shin — PR triage - -# LLM-as-judge triage for external pull requests. -# -# DRY-RUN BY DEFAULT. Closures and public comments are gated on the repo -# variable `AGENT_SHIN_ENABLED` being set to the string `"true"`. Until then, -# every run only writes its verdict to the workflow step summary so the team -# can QA the judge's decisions before flipping it on. -# -# To enable for real: -# 1. Add a repo secret `OPENAI_API_KEY` (or compatible). -# 2. Set repo variable `AGENT_SHIN_ENABLED` to `true` -# (Settings > Secrets and variables > Actions > Variables). -# -# We use `pull_request_target` so the workflow has access to repo secrets -# and runs against PRs from forks. We never check out fork code — only read -# PR metadata via `gh api`, so this is safe. - -on: - pull_request_target: - types: [opened, reopened] - workflow_dispatch: - inputs: - pr_number: - description: "PR number to triage manually." - required: true - close: - description: "If true and AGENT_SHIN_ENABLED=true, actually close on fail." - required: false - default: "false" - type: choice - options: - - "true" - - "false" - -permissions: - contents: read - issues: write - pull-requests: write - -jobs: - triage: - if: github.repository == 'BerriAI/litellm' - runs-on: ubuntu-latest - steps: - - name: Checkout triage script - uses: actions/checkout@08eba0b27e820071cde6df949e0beb9ba4906955 # v4.3.0 - with: - sparse-checkout: .github/scripts - persist-credentials: false - - - name: Set up Python - uses: actions/setup-python@a26af69be951a213d495a4c3e4e4022e16d87065 # v5.6.0 - with: - python-version: "3.12" - - - name: Install LLM client - run: pip install --no-cache-dir --require-hashes -r .github/scripts/triage-requirements.txt - - - name: Run Agent Shin - env: - GH_TOKEN: ${{ secrets.GITHUB_TOKEN }} - # Only expose the LLM key when the bot is enabled or a collaborator - # triggers it manually, so an external user can't force paid LLM - # calls by churning a fork PR while the bot is still in dry-run. - # The Python script calls the LLM whenever this var is set - # (regardless of `--close`); stripping `--close` doesn't suppress - # the API call, only the destructive side effects. - OPENAI_API_KEY: ${{ (vars.AGENT_SHIN_ENABLED == 'true' || github.event_name == 'workflow_dispatch') && secrets.OPENAI_API_KEY || '' }} - OPENAI_BASE_URL: ${{ vars.OPENAI_BASE_URL }} - TRIAGE_MODEL: ${{ vars.TRIAGE_MODEL }} - AGENT_SHIN_ENABLED: ${{ vars.AGENT_SHIN_ENABLED }} - DISPATCH_CLOSE: ${{ github.event.inputs.close }} - PR_NUMBER: ${{ github.event.pull_request.number || github.event.inputs.pr_number }} - run: | - set -euo pipefail - ARGS=(--repo "${{ github.repository }}" --pr "${PR_NUMBER}") - # Fail-safe gating: only the EXACT string "true" enables the - # destructive --close path. The workflow_dispatch input is a - # `choice` dropdown of "true"/"false" so the UI is constrained, - # but the API (`gh workflow run -f close=...`) accepts any - # string, and a `!= "false"` check would treat "True", "yes", - # "1", "TRUE", typos, and accidental whitespace as enabling - # closure. Mirror the Greptile closer's `= "true"` pattern. - if [ "${AGENT_SHIN_ENABLED:-false}" = "true" ] && [ "${DISPATCH_CLOSE:-false}" = "true" ]; then - ARGS+=(--close) - echo "::notice::Agent Shin is ENABLED and running in close-on-fail mode." - elif [ "${AGENT_SHIN_ENABLED:-false}" = "true" ]; then - echo "::notice::Agent Shin is ENABLED but this trigger is dry-run (workflow_dispatch close != 'true' or scheduled event)." - else - echo "::notice::Agent Shin is in DRY-RUN mode (AGENT_SHIN_ENABLED is not 'true'). No comments will be posted; no PRs will be closed." - fi - # On the scheduled/automatic pull_request_target trigger we default to - # dry-run regardless, so the team can review verdicts in the step - # summary before any contributor sees a comment. Only the manual - # workflow_dispatch path (with close=true) closes PRs. - if [ "${GITHUB_EVENT_NAME:-}" = "pull_request_target" ]; then - # strip any --close added above (filter out, don't substitute - # to empty string — that would leave a stray "" positional arg - # that argparse rejects) - FILTERED=() - for arg in "${ARGS[@]}"; do - if [ "${arg}" != "--close" ]; then - FILTERED+=("${arg}") - fi - done - ARGS=("${FILTERED[@]}") - echo "::notice::pull_request_target trigger -> forcing dry-run." - fi - python3 .github/scripts/triage_with_llm.py "${ARGS[@]}" diff --git a/.github/workflows/zizmor.yml b/.github/workflows/zizmor.yml index 9a1e899fed5..db79fe43038 100644 --- a/.github/workflows/zizmor.yml +++ b/.github/workflows/zizmor.yml @@ -2,9 +2,9 @@ name: GitHub Actions Security Analysis on: push: - branches: [main] + branches: [main, litellm_internal_staging] pull_request: - branches: [main] + branches: [main, litellm_internal_staging] concurrency: group: ${{ github.workflow }}-${{ github.event.pull_request.number || github.ref }} @@ -18,9 +18,7 @@ jobs: runs-on: ubuntu-latest timeout-minutes: 5 permissions: - security-events: write contents: read - actions: read steps: - name: Checkout repository uses: actions/checkout@08eba0b27e820071cde6df949e0beb9ba4906955 # v4.3.0 @@ -28,4 +26,9 @@ jobs: persist-credentials: false - name: Run zizmor - uses: zizmorcore/zizmor-action@71321a20a9ded102f6e9ce5718a2fcec2c4f70d8 # v0.5.2 + uses: zizmorcore/zizmor-action@5f14fd08f7cf1cb1609c1e344975f152c7ee938d # v0.5.6 + with: + version: "1.24.1" + min-severity: medium + advanced-security: false + annotations: true diff --git a/README.md b/README.md index d7dc665dcec..b26ad39eada 100644 --- a/README.md +++ b/README.md @@ -345,6 +345,7 @@ curl -X POST 'http://0.0.0.0:4000/v1/chat/completions' \ | [OVHCloud AI Endpoints (`ovhcloud`)](https://docs.litellm.ai/docs/providers/ovhcloud) | ✅ | ✅ | ✅ | | | | | | | | | [Perplexity AI (`perplexity`)](https://docs.litellm.ai/docs/providers/perplexity) | ✅ | ✅ | ✅ | | | | | | | | | [Petals (`petals`)](https://docs.litellm.ai/docs/providers/petals) | ✅ | ✅ | ✅ | | | | | | | | +| [Pinstripes (`pinstripes`)](https://docs.litellm.ai/docs/providers/pinstripes) | ✅ | ✅ | ✅ | | | | | | | | | [Predibase (`predibase`)](https://docs.litellm.ai/docs/providers/predibase) | ✅ | ✅ | ✅ | | | | | | | | | [Recraft (`recraft`)](https://docs.litellm.ai/docs/providers/recraft) | | | | | ✅ | | | | | | | [Replicate (`replicate`)](https://docs.litellm.ai/docs/providers/replicate) | ✅ | ✅ | ✅ | | | | | | | | diff --git a/basedpyright-code-budget.json b/basedpyright-code-budget.json index 73bc5c47703..7ba7656e407 100644 --- a/basedpyright-code-budget.json +++ b/basedpyright-code-budget.json @@ -1,31 +1,31 @@ { "reportAny": { - "baseline": 24954, + "baseline": 24989, "slack": 2500 }, "reportArgumentType": { - "baseline": 1863, + "baseline": 1934, "slack": 180 }, "reportAssignmentType": { "baseline": 220, - "slack": 3 + "slack": 22 }, "reportAttributeAccessIssue": { - "baseline": 335, - "slack": 3 + "baseline": 346, + "slack": 35 }, "reportCallIssue": { - "baseline": 77, + "baseline": 87, "slack": 10 }, "reportConstantRedefinition": { "baseline": 39, - "slack": 3 + "slack": 4 }, "reportDeprecated": { "baseline": 217, - "slack": 10 + "slack": 22 }, "reportDuplicateImport": { "baseline": 28, @@ -41,11 +41,11 @@ }, "reportGeneralTypeIssues": { "baseline": 151, - "slack": 3 + "slack": 15 }, "reportIncompatibleMethodOverride": { "baseline": 52, - "slack": 10 + "slack": 5 }, "reportIncompatibleVariableOverride": { "baseline": 8, @@ -73,7 +73,7 @@ }, "reportMissingParameterType": { "baseline": 3933, - "slack": 10 + "slack": 390 }, "reportMissingTypeArgument": { "baseline": 10612, @@ -97,7 +97,7 @@ }, "reportOptionalMemberAccess": { "baseline": 724, - "slack": 10 + "slack": 72 }, "reportOptionalOperand": { "baseline": 3, @@ -120,8 +120,8 @@ "slack": 3 }, "reportReturnType": { - "baseline": 118, - "slack": 10 + "baseline": 126, + "slack": 13 }, "reportTypedDictNotRequiredAccess": { "baseline": 20, @@ -136,19 +136,19 @@ "slack": 3000 }, "reportUnknownLambdaType": { - "baseline": 76, + "baseline": 75, "slack": 10 }, "reportUnknownMemberType": { - "baseline": 27322, + "baseline": 27037, "slack": 2500 }, "reportUnknownParameterType": { - "baseline": 13636, + "baseline": 13612, "slack": 1000 }, "reportUnknownVariableType": { - "baseline": 21776, + "baseline": 21445, "slack": 2000 }, "reportUnnecessaryCast": { @@ -156,7 +156,7 @@ "slack": 10 }, "reportUnnecessaryComparison": { - "baseline": 680, + "baseline": 683, "slack": 10 }, "reportUnnecessaryContains": { @@ -164,12 +164,12 @@ "slack": 3 }, "reportUnnecessaryIsInstance": { - "baseline": 807, - "slack": 10 + "baseline": 808, + "slack": 80 }, "reportUntypedBaseClass": { "baseline": 110, - "slack": 3 + "slack": 11 }, "reportUntypedFunctionDecorator": { "baseline": 22, @@ -185,10 +185,10 @@ }, "reportUnusedImport": { "baseline": 670, - "slack": 10 + "slack": 50 }, "reportUnusedVariable": { "baseline": 865, - "slack": 10 + "slack": 50 } } diff --git a/enterprise/litellm_enterprise/proxy/hooks/managed_files.py b/enterprise/litellm_enterprise/proxy/hooks/managed_files.py index 6830147116d..8486e37384e 100644 --- a/enterprise/litellm_enterprise/proxy/hooks/managed_files.py +++ b/enterprise/litellm_enterprise/proxy/hooks/managed_files.py @@ -1,9 +1,9 @@ # What is this? ## This hook is used to check for LiteLLM managed files in the request body, and replace them with model-specific file id -import asyncio import base64 import json +from types import MappingProxyType from typing import TYPE_CHECKING, Any, Dict, List, Literal, Optional, Union, cast from fastapi import HTTPException @@ -1472,8 +1472,8 @@ class _PROXY_LiteLLMManagedFiles(CustomLogger, BaseFileEndpoints): error_message += f" (showing {MAX_BATCHES_IN_ERROR} most recent): {', '.join(batch_statuses)}. " error_message += ( - f"To delete this file before complete cost tracking, please delete or cancel the referencing batch(es) first. " - f"Alternatively, wait for all batches to complete and for cost to be computed (batch_processed=true)." + "To delete this file before complete cost tracking, please delete or cancel the referencing batch(es) first. " + "Alternatively, wait for all batches to complete and for cost to be computed (batch_processed=true)." ) # Record blocked deletion metric @@ -1550,9 +1550,22 @@ class _PROXY_LiteLLMManagedFiles(CustomLogger, BaseFileEndpoints): if specific_model_file_id_mapping: exception_dict = {} - for model_id, file_id in specific_model_file_id_mapping.items(): + for model_id, provider_file_id in specific_model_file_id_mapping.items(): try: - return await llm_router.afile_content(model=model_id, file_id=file_id, **data) # type: ignore + # Cloud-storage providers (e.g. Bedrock S3) validate file ids + # against the deployment's configured bucket, which they only + # trust from this immutable server-side snapshot, never from + # request params. + credentials = llm_router.get_deployment_credentials_with_provider( + model_id=model_id + ) + if credentials is not None: + data["_litellm_internal_model_credentials"] = cast( + Dict, MappingProxyType(dict(credentials)) + ) + else: + data.pop("_litellm_internal_model_credentials", None) + return await llm_router.afile_content(model=model_id, file_id=provider_file_id, **data) # type: ignore except Exception as e: exception_dict[model_id] = str(e) raise Exception( diff --git a/litellm/caching/caching.py b/litellm/caching/caching.py index 997ad10bc33..cb122e90102 100644 --- a/litellm/caching/caching.py +++ b/litellm/caching/caching.py @@ -100,6 +100,8 @@ class Cache: gcs_path: Optional[str] = None, redis_semantic_cache_embedding_model: str = "text-embedding-ada-002", redis_semantic_cache_index_name: Optional[str] = None, + valkey_semantic_cache_embedding_model: str = "text-embedding-ada-002", + valkey_semantic_cache_index_name: str | None = None, redis_flush_size: Optional[int] = None, redis_startup_nodes: Optional[List] = None, disk_cache_dir: Optional[str] = None, @@ -208,6 +210,21 @@ class Cache: index_name=redis_semantic_cache_index_name, **kwargs, ) + elif type == LiteLLMCacheType.VALKEY_SEMANTIC: + # Imported here, not at module top, so the optional redis dependency + # is only required when this backend is actually selected. + from .valkey_semantic_cache import ValkeySemanticCache + + self.cache = ValkeySemanticCache( + host=host, + port=port, + password=password, + similarity_threshold=similarity_threshold, + embedding_model=valkey_semantic_cache_embedding_model, + index_name=valkey_semantic_cache_index_name, + startup_nodes=redis_startup_nodes, + **kwargs, + ) elif type == LiteLLMCacheType.QDRANT_SEMANTIC: self.cache = QdrantSemanticCache( qdrant_api_base=qdrant_api_base, @@ -267,12 +284,50 @@ class Cache: if ( self.type == LiteLLMCacheType.REDIS or self.type == LiteLLMCacheType.REDIS_SEMANTIC + or self.type == LiteLLMCacheType.VALKEY_SEMANTIC ) and default_in_redis_ttl is not None: self.ttl = default_in_redis_ttl if self.namespace is not None and isinstance(self.cache, RedisCache): self.cache.namespace = self.namespace + # Params whose values carry prompt content. Excluded from semantic-cache + # scope keys so differently worded prompts share a bucket and match via + # vector similarity rather than being split into per-wording buckets. + _SEMANTIC_CACHE_SCOPE_EXCLUDED_PARAMS: frozenset = frozenset( + {"messages", "prompt", "input"} + ) + + # Server-set identity (from proxy auth) used to isolate semantic-cache + # buckets per tenant. Required once the prompt is out of the scope key, so a + # similar prompt from another key/team/org stays in a separate bucket. + _SEMANTIC_CACHE_TENANT_SCOPE_FIELDS: tuple[str, ...] = ( + "user_api_key", + "user_api_key_team_id", + "user_api_key_org_id", + ) + + def _is_semantic_cache(self) -> bool: + return self.type in ( + LiteLLMCacheType.REDIS_SEMANTIC, + LiteLLMCacheType.QDRANT_SEMANTIC, + LiteLLMCacheType.VALKEY_SEMANTIC, + ) + + def _get_semantic_cache_tenant_scope(self, kwargs: dict) -> str: + metadata: dict = kwargs.get("metadata") or {} + litellm_params: dict = kwargs.get("litellm_params") or {} + metadata_in_litellm_params: dict = litellm_params.get("metadata") or {} + + scope = "" + for field in self._SEMANTIC_CACHE_TENANT_SCOPE_FIELDS: + value = metadata.get(field) + if value is None: + value = metadata_in_litellm_params.get(field) + if value is not None: + scope += f"{field}: {value}" + return scope + def get_cache_key(self, **kwargs) -> str: """ Get the cache key for the given arguments. @@ -293,7 +348,15 @@ class Cache: combined_kwargs = ModelParamHelper._get_all_llm_api_params() litellm_param_kwargs = all_litellm_params + is_semantic_cache = self._is_semantic_cache() + scope_excluded_params = ( + self._SEMANTIC_CACHE_SCOPE_EXCLUDED_PARAMS + if is_semantic_cache + else frozenset() + ) for param in kwargs: + if param in scope_excluded_params: + continue if param in combined_kwargs: param_value: Optional[str] = self._get_param_value(param, kwargs) if param_value is not None: @@ -309,6 +372,9 @@ class Cache: param_value = kwargs[param] cache_key += f"{str(param)}: {str(param_value)}" + if is_semantic_cache: + cache_key += self._get_semantic_cache_tenant_scope(kwargs) + hashed_cache_key = Cache._get_hashed_cache_key(cache_key) hashed_cache_key = self._add_namespace_to_cache_key(hashed_cache_key, **kwargs) verbose_logger.debug( diff --git a/litellm/caching/gcs_cache.py b/litellm/caching/gcs_cache.py index 3327e094bc2..0e6a111eb2b 100644 --- a/litellm/caching/gcs_cache.py +++ b/litellm/caching/gcs_cache.py @@ -5,6 +5,7 @@ Supports syncing responses to Google Cloud Storage Buckets using HTTP requests. import json import asyncio from typing import Optional +from urllib.parse import quote from litellm._logging import print_verbose, verbose_logger from litellm.integrations.gcs_bucket.gcs_bucket_base import GCSBucketBase @@ -48,7 +49,7 @@ class GCSCache(BaseCache): headers = self._construct_headers() object_name = self.key_prefix + key bucket_name = self.bucket_name - url = f"https://storage.googleapis.com/upload/storage/v1/b/{bucket_name}/o?uploadType=media&name={object_name}" + url = f"https://storage.googleapis.com/upload/storage/v1/b/{bucket_name}/o?uploadType=media&name={quote(object_name, safe='')}" data = json.dumps(value) self.sync_client.post(url=url, data=data, headers=headers) except Exception as e: @@ -59,7 +60,7 @@ class GCSCache(BaseCache): headers = self._construct_headers() object_name = self.key_prefix + key bucket_name = self.bucket_name - url = f"https://storage.googleapis.com/upload/storage/v1/b/{bucket_name}/o?uploadType=media&name={object_name}" + url = f"https://storage.googleapis.com/upload/storage/v1/b/{bucket_name}/o?uploadType=media&name={quote(object_name, safe='')}" data = json.dumps(value) await self.async_client.post(url=url, data=data, headers=headers) except Exception as e: @@ -72,7 +73,7 @@ class GCSCache(BaseCache): headers = self._construct_headers() object_name = self.key_prefix + key bucket_name = self.bucket_name - url = f"https://storage.googleapis.com/storage/v1/b/{bucket_name}/o/{object_name}?alt=media" + url = f"https://storage.googleapis.com/storage/v1/b/{bucket_name}/o/{quote(object_name, safe='')}?alt=media" response = self.sync_client.get(url=url, headers=headers) if response.status_code == 200: cached_response = json.loads(response.text) @@ -91,7 +92,7 @@ class GCSCache(BaseCache): headers = self._construct_headers() object_name = self.key_prefix + key bucket_name = self.bucket_name - url = f"https://storage.googleapis.com/storage/v1/b/{bucket_name}/o/{object_name}?alt=media" + url = f"https://storage.googleapis.com/storage/v1/b/{bucket_name}/o/{quote(object_name, safe='')}?alt=media" response = await self.async_client.get(url=url, headers=headers) if response.status_code == 200: return json.loads(response.text) diff --git a/litellm/caching/redis_cache.py b/litellm/caching/redis_cache.py index 263e1df2ee7..ba07511448a 100644 --- a/litellm/caching/redis_cache.py +++ b/litellm/caching/redis_cache.py @@ -903,6 +903,43 @@ class RedisCache(BaseCache): ) raise e + @_redis_circuit_breaker_guard + async def async_set_max( + self, + key: str, + value: float, + ttl: int | None = None, + ) -> float | None: + """Atomically set ``key`` to ``value`` only when ``value`` is greater + than the stored value (or the key is unset), refreshing the TTL. + + Monotonic by construction: it never lowers the stored value, so a repair + that writes an authoritative-but-slightly-stale total cannot clobber a + concurrent increment that has already pushed the counter higher. The + GET/compare/SET runs in a single Lua call, so it is also atomic across + racing callers and pods. Returns the resulting value. + """ + _redis_client = self.init_async_client() + _used_ttl = self.get_ttl(ttl=ttl) + key = self.check_and_fix_namespace(key=key) + lua = ( + "local cur = redis.call('GET', KEYS[1]) " + "if cur == false or tonumber(cur) < tonumber(ARGV[1]) then " + "redis.call('SET', KEYS[1], ARGV[1]) " + "if tonumber(ARGV[2]) > 0 then redis.call('EXPIRE', KEYS[1], ARGV[2]) end " + "return ARGV[1] end " + "return cur" + ) + result = cast( + "str | bytes | int | float | None", + await _redis_client.eval(lua, 1, key, str(value), str(int(_used_ttl or 0))), + ) + if result is None: + return None + if isinstance(result, bytes): + result = result.decode() + return float(result) + async def flush_cache_buffer(self): print_verbose( f"flushing to redis....reached size of buffer {len(self.redis_batch_writing_buffer)}" diff --git a/litellm/caching/valkey_semantic_cache.py b/litellm/caching/valkey_semantic_cache.py new file mode 100644 index 00000000000..bf368b74d07 --- /dev/null +++ b/litellm/caching/valkey_semantic_cache.py @@ -0,0 +1,353 @@ +""" +Valkey Semantic Cache implementation for LiteLLM + +Backs semantic caching with Valkey (for example AWS ElastiCache for Valkey) +running the valkey-search module. + +RedisVL cannot drive valkey-search: it gates on a RediSearch module version +that valkey-search does not report, and its SemanticCache index uses a TEXT +field that valkey-search does not implement. This backend therefore talks to +valkey-search directly over redis-py, building a vector index from the field +types valkey-search does support (TAG for cache-key isolation and VECTOR for +the prompt embedding) and running KNN queries for retrieval. Prompt extraction, +embedding generation, and cached-response parsing are reused from +RedisSemanticCache since those are backend agnostic. +""" + +import asyncio +import hashlib +import os +import struct +from dataclasses import dataclass +from typing import Any + +from redis import Redis +from redis.asyncio import Redis as AsyncRedis +from redis.commands.search.field import TagField, VectorField +from redis.commands.search.indexDefinition import IndexDefinition, IndexType +from redis.commands.search.query import Query + +from litellm._logging import print_verbose +from litellm._uuid import uuid + +from .redis_semantic_cache import RedisSemanticCache + + +@dataclass(frozen=True, slots=True) +class _ValkeyCacheHit: + response: str + distance: float + + +class ValkeySemanticCache(RedisSemanticCache): + """Valkey-backed semantic cache for LLM responses.""" + + DEFAULT_VALKEY_INDEX_NAME: str = "litellm_semantic_cache_index" + EMBEDDING_FIELD_NAME: str = "embedding" + PROMPT_FIELD_NAME: str = "prompt" + RESPONSE_FIELD_NAME: str = "response" + DISTANCE_FIELD_NAME: str = "vector_distance" + + def __init__( + self, + host: str | None = None, + port: str | None = None, + password: str | None = None, + redis_url: str | None = None, + similarity_threshold: float | None = None, + embedding_model: str = "text-embedding-ada-002", + index_name: str | None = None, + ssl: bool = False, + startup_nodes: list | None = None, + sync_client: Redis | None = None, + async_client: AsyncRedis | None = None, + **kwargs: Any, + ): + if similarity_threshold is None: + raise ValueError("similarity_threshold must be provided, passed None") + + if startup_nodes: + raise ValueError( + "valkey-semantic does not support cluster-mode-enabled (multi-shard) " + "endpoints. The async cluster client cannot route the FT.* search " + "commands reliably. Point it at a cluster-mode-disabled endpoint " + "instead (a primary with replicas is fine; only horizontal sharding " + "is unsupported), or pass a single redis_url. On AWS, vector search " + "needs ElastiCache for Valkey 8.2+ on a node-based cluster." + ) + + self.similarity_threshold = similarity_threshold + self.embedding_model = embedding_model + self.index_name = index_name or self.DEFAULT_VALKEY_INDEX_NAME + self.key_prefix = f"{self.index_name}:" + self._index_dim: int | None = None + + resolved_url = None + if sync_client is None or async_client is None: + resolved_url = redis_url or self._build_valkey_url( + host, port, password, ssl + ) + self.sync_client = ( + sync_client if sync_client is not None else Redis.from_url(resolved_url) # type: ignore[arg-type] + ) + self.async_client = ( + async_client + if async_client is not None + else AsyncRedis.from_url(resolved_url) # type: ignore[arg-type] + ) + + print_verbose(f"Valkey semantic-cache initializing index - {self.index_name}") + + @staticmethod + def _build_valkey_url( + host: str | None, port: str | None, password: str | None, ssl: bool = False + ) -> str: + host = host or os.environ.get("VALKEY_HOST") or os.environ.get("REDIS_HOST") + port = port or os.environ.get("VALKEY_PORT") or os.environ.get("REDIS_PORT") + password = ( + password + or os.environ.get("VALKEY_PASSWORD") + or os.environ.get("REDIS_PASSWORD") + ) + + if not host or not port: + raise ValueError( + "Missing required Valkey configuration. Provide host and port " + "(or VALKEY_HOST/VALKEY_PORT), or pass redis_url." + ) + + credentials = f":{password}@" if password else "" + scheme = "rediss" if ssl else "redis" + return f"{scheme}://{credentials}{host}:{port}" + + @classmethod + def _scope_tag(cls, key: str) -> str: + # valkey-search TAG fields tokenize on punctuation and do not honour + # backslash escaping, so an arbitrary cache key cannot be matched + # verbatim. Hashing to hex yields a token that is always exact-match + # safe and still uniquely isolates a caller's scope. + return hashlib.sha256(str(key).encode("utf-8")).hexdigest() + + @staticmethod + def _embedding_to_bytes(embedding: list[float]) -> bytes: + return struct.pack(f"<{len(embedding)}f", *embedding) + + def _index_schema(self, dim: int) -> tuple[TagField, VectorField]: + return ( + TagField(self.CACHE_KEY_FIELD_NAME), + VectorField( + self.EMBEDDING_FIELD_NAME, + "HNSW", + {"TYPE": "FLOAT32", "DIM": dim, "DISTANCE_METRIC": "COSINE"}, + ), + ) + + def _index_definition(self) -> IndexDefinition: + return IndexDefinition(prefix=[self.key_prefix], index_type=IndexType.HASH) + + @staticmethod + def _is_index_exists_error(exc: Exception) -> bool: + return "already exists" in str(exc).lower() + + @staticmethod + def _extract_index_dim(info: dict) -> int | None: + # FT.INFO nests the vector field's "dimensions" one level inside its + # "index" block, so flatten each field descriptor a single level and + # scan for the dimensions marker. + for field in info.get("attributes") or []: + if not isinstance(field, (list, tuple)): + continue + flat = [ + sub + for item in field + for sub in (item if isinstance(item, (list, tuple)) else [item]) + ] + for i, marker in enumerate(flat): + if marker in (b"dimensions", "dimensions") and i + 1 < len(flat): + return int(flat[i + 1]) + return None + + def _assert_dim_matches(self, info: dict, dim: int) -> None: + existing_dim = self._extract_index_dim(info) + if existing_dim is not None and existing_dim != dim: + raise ValueError( + f"Valkey semantic-cache index '{self.index_name}' already exists with " + f"embedding dimension {existing_dim}, but the configured embedding " + f"model produced dimension {dim}. Use a different " + f"valkey_semantic_cache_index_name or drop the existing index." + ) + + def _ensure_index_sync(self, dim: int) -> None: + if self._index_dim == dim: + return + try: + self.sync_client.ft(self.index_name).create_index( + self._index_schema(dim), definition=self._index_definition() + ) + except Exception as exc: + if not self._is_index_exists_error(exc): + raise + self._assert_dim_matches(self.sync_client.ft(self.index_name).info(), dim) + self._index_dim = dim + + async def _ensure_index_async(self, dim: int) -> None: + if self._index_dim == dim: + return + try: + await self.async_client.ft(self.index_name).create_index( + self._index_schema(dim), definition=self._index_definition() + ) + except Exception as exc: + if not self._is_index_exists_error(exc): + raise + info = await self.async_client.ft(self.index_name).info() + self._assert_dim_matches(info, dim) + self._index_dim = dim + + def _doc_key(self, key: str) -> str: + return f"{self.key_prefix}{self._scope_tag(key)}:{uuid.uuid4()}" + + def _doc_mapping( + self, key: str, prompt: str, value_str: str, embedding: list[float] + ) -> dict: + return { + self.CACHE_KEY_FIELD_NAME: self._scope_tag(key), + self.PROMPT_FIELD_NAME: prompt, + self.RESPONSE_FIELD_NAME: value_str, + self.EMBEDDING_FIELD_NAME: self._embedding_to_bytes(embedding), + } + + def _knn_query(self, key: str) -> Query: + scope = self._scope_tag(key) + query_string = ( + f"(@{self.CACHE_KEY_FIELD_NAME}:{{{scope}}})" + f"=>[KNN 1 @{self.EMBEDDING_FIELD_NAME} $vec AS {self.DISTANCE_FIELD_NAME}]" + ) + return ( + Query(query_string) + .return_fields(self.RESPONSE_FIELD_NAME, self.DISTANCE_FIELD_NAME) + .dialect(2) + ) + + @classmethod + def _first_hit(cls, search_result: Any) -> _ValkeyCacheHit | None: + docs = getattr(search_result, "docs", []) + if not docs: + return None + doc = docs[0] + return _ValkeyCacheHit( + response=str(getattr(doc, cls.RESPONSE_FIELD_NAME)), + distance=float(getattr(doc, cls.DISTANCE_FIELD_NAME)), + ) + + def _resolve_hit(self, hit: _ValkeyCacheHit | None, key: str, **kwargs: Any) -> Any: + if hit is None: + kwargs.setdefault("metadata", {})["semantic-similarity"] = 0.0 + return None + + similarity = 1 - hit.distance + kwargs.setdefault("metadata", {})["semantic-similarity"] = similarity + + if similarity < self.similarity_threshold: + return None + return self._get_cache_logic(cached_response=hit.response) + + def set_cache(self, key: str, value: Any, **kwargs: Any) -> None: + print_verbose(f"Valkey semantic-cache set_cache, kwargs: {kwargs}") + try: + prompt = self._get_prompt_from_kwargs(**kwargs) + if prompt is None: + print_verbose("No prompt provided for semantic caching") + return + + embedding = self._get_embedding(prompt) + self._ensure_index_sync(len(embedding)) + + doc_key = self._doc_key(key) + self.sync_client.hset( + doc_key, mapping=self._doc_mapping(key, prompt, str(value), embedding) + ) + ttl = self._get_ttl(**kwargs) + if ttl is not None: + self.sync_client.expire(doc_key, ttl) + except Exception as e: + print_verbose(f"Error in Valkey semantic-cache set_cache: {str(e)}") + + def get_cache(self, key: str, **kwargs: Any) -> Any: + print_verbose(f"Valkey semantic-cache get_cache, kwargs: {kwargs}") + try: + prompt = self._get_prompt_from_kwargs(**kwargs) + if prompt is None: + kwargs.setdefault("metadata", {})["semantic-similarity"] = 0.0 + return None + + embedding = self._get_embedding(prompt) + self._ensure_index_sync(len(embedding)) + + search_result = self.sync_client.ft(self.index_name).search( + self._knn_query(key), + query_params={"vec": self._embedding_to_bytes(embedding)}, + ) + return self._resolve_hit(self._first_hit(search_result), key, **kwargs) + except Exception as e: + print_verbose(f"Error in Valkey semantic-cache get_cache: {str(e)}") + kwargs.setdefault("metadata", {})["semantic-similarity"] = 0.0 + + async def async_set_cache(self, key: str, value: Any, **kwargs: Any) -> None: + print_verbose(f"Async Valkey semantic-cache set_cache, kwargs: {kwargs}") + try: + prompt = self._get_prompt_from_kwargs(**kwargs) + if prompt is None: + print_verbose("No prompt provided for semantic caching") + return + + embedding = await self._get_async_embedding(prompt, **kwargs) + await self._ensure_index_async(len(embedding)) + + doc_key = self._doc_key(key) + await self.async_client.hset( + doc_key, mapping=self._doc_mapping(key, prompt, str(value), embedding) + ) + ttl = self._get_ttl(**kwargs) + if ttl is not None: + await self.async_client.expire(doc_key, ttl) + except Exception as e: + print_verbose(f"Error in async Valkey semantic-cache set_cache: {str(e)}") + + async def async_get_cache(self, key: str, **kwargs: Any) -> Any: + print_verbose(f"Async Valkey semantic-cache get_cache, kwargs: {kwargs}") + try: + prompt = self._get_prompt_from_kwargs(**kwargs) + if prompt is None: + kwargs.setdefault("metadata", {})["semantic-similarity"] = 0.0 + return None + + embedding = await self._get_async_embedding(prompt, **kwargs) + await self._ensure_index_async(len(embedding)) + + search_result = await self.async_client.ft(self.index_name).search( + self._knn_query(key), + query_params={"vec": self._embedding_to_bytes(embedding)}, + ) + return self._resolve_hit(self._first_hit(search_result), key, **kwargs) + except Exception as e: + print_verbose(f"Error in async Valkey semantic-cache get_cache: {str(e)}") + kwargs.setdefault("metadata", {})["semantic-similarity"] = 0.0 + + async def async_set_cache_pipeline( + self, cache_list: list[tuple[str, Any]], **kwargs: Any + ) -> None: + try: + await asyncio.gather( + *[ + self.async_set_cache(key, value, **kwargs) + for key, value in cache_list + ] + ) + except Exception as e: + print_verbose( + f"Error in Valkey semantic-cache async_set_cache_pipeline: {str(e)}" + ) + + async def _index_info(self) -> dict: + return await self.async_client.ft(self.index_name).info() diff --git a/litellm/constants.py b/litellm/constants.py index a3ea68c7949..c0e265c0e4a 100644 --- a/litellm/constants.py +++ b/litellm/constants.py @@ -802,6 +802,7 @@ openai_compatible_endpoints: List = [ "https://api.inference.wandb.ai/v1", "https://api.clarifai.com/v2/ext/openai/v1", "https://api.libertai.io/v1", + "https://pinstripes.io/v1", ] @@ -865,6 +866,7 @@ openai_compatible_providers: List = [ "clarifai", "docker_model_runner", "ragflow", + "pinstripes", # Pinstripes - JSON-configured provider ] openai_text_completion_compatible_providers: List = ( [ # providers that support `/v1/completions` diff --git a/litellm/integrations/otel/logger.py b/litellm/integrations/otel/logger.py index 1869e9ca388..79931c0796c 100644 --- a/litellm/integrations/otel/logger.py +++ b/litellm/integrations/otel/logger.py @@ -3,7 +3,7 @@ from collections import OrderedDict from contextlib import contextmanager from datetime import datetime -from typing import TYPE_CHECKING, Any, Iterator, Mapping, cast +from typing import TYPE_CHECKING, Any, Callable, Iterator, Mapping, Sequence, cast from opentelemetry.context import attach, get_current from opentelemetry.sdk.trace import TracerProvider @@ -546,6 +546,58 @@ class OpenTelemetryV2(CustomLogger): return span +def select_global_otel_v2_logger( + in_memory_loggers: Sequence[object], + registered: "OpenTelemetryV2 | None" = None, +) -> "OpenTelemetryV2": + """The single ``OpenTelemetryV2`` whose provider should become the OTel global. + + The callback factory designates one logger as canonical the moment it builds + the first one (``_init_otel_logger_on_litellm_proxy`` sets + ``proxy_server.open_telemetry_logger``), and every other v2 entry point — + guardrail, identity seeding, phase spans — already routes through that same + ``registered`` owner. Reuse it here too so the global provider has one source + of truth instead of a second, independently-derived guess; this is the logger + a preset (arize, langfuse, …) folds the ``OTEL_*`` base exporter and its own + exporter into, so the FastAPI server span and the gen-ai spans share one + provider and one trace. + + Fall back to ``in_memory_loggers`` for the SDK path, where no proxy global is + set (selecting from there, not ``service_callback``, which a preset logger does + not always reach), and build a generic logger from ``OTEL_*`` only when none was + configured at all. Each fallback still avoids the second generic logger that + orphaned the gen-ai spans onto a different backend than the server span. + """ + if registered is not None: + return registered + existing = next( + (cb for cb in in_memory_loggers if isinstance(cb, OpenTelemetryV2)), None + ) + return existing if existing is not None else OpenTelemetryV2() + + +def publish_global_otel_v2_provider( + in_memory_loggers: Sequence[object], + set_global_provider: Callable[[TracerProvider], None], + registered: "OpenTelemetryV2 | None" = None, +) -> "OpenTelemetryV2": + """Select the single v2 logger and publish its provider as the OTel global. + + The proxy calls this once at startup, after callbacks are initialized, so the + preset logger already exists; it passes ``registered`` (the canonical owner the + factory designated as ``proxy_server.open_telemetry_logger``) so the global + provider reuses the same logger the rest of the v2 code emits through (see + :func:`select_global_otel_v2_logger`). Both ``registered`` and + ``set_global_provider`` (the proxy passes + ``opentelemetry.trace.set_tracer_provider``) are injected so the publish step is + unit-testable without reading or mutating real global OTel state. Returns the + logger whose provider was published. + """ + logger = select_global_otel_v2_logger(in_memory_loggers, registered=registered) + set_global_provider(logger._tracer_provider) + return logger + + def _registered_v2_logger() -> "OpenTelemetryV2 | None": try: from litellm.proxy import proxy_server diff --git a/litellm/integrations/otel/model/config.py b/litellm/integrations/otel/model/config.py index 4f7c3277ebb..a109ba898ff 100644 --- a/litellm/integrations/otel/model/config.py +++ b/litellm/integrations/otel/model/config.py @@ -1,5 +1,6 @@ """Typed configuration for the OpenTelemetry instrumentation.""" +from enum import Enum from typing import Any, List from pydantic import AliasChoices, BaseModel, Field, field_validator, model_validator @@ -23,6 +24,23 @@ class CaptureMessageContent(str): SPAN_AND_EVENT = "span_and_event" +class ExporterOwner(str, Enum): + """The preset that contributed an exporter. Values match the callback names + in ``presets.PRESET_BY_CALLBACK`` so per-request dynamic-credential routing + can match an exporter's owner against the credential source's callback name. + A ``str`` enum so the value compares equal to the bare callback-name string.""" + + # Arize AX (the hosted platform) and Arize Phoenix (the open-source / Phoenix + # Cloud tracer) are distinct backends with separate config and auth, so they + # are separate owners. The member value stays the public callback name. + ARIZE_AX = "arize" + ARIZE_PHOENIX = "arize_phoenix" + LANGFUSE_OTEL = "langfuse_otel" + WEAVE_OTEL = "weave_otel" + LEVO = "levo" + AGENTOPS = "agentops" + + class _OTelV2Flag(BaseSettings): model_config = SettingsConfigDict(extra="ignore") @@ -49,6 +67,15 @@ class ExporterSpec(BaseModel): ) endpoint: str | None = None headers: str | None = None + owner: ExporterOwner | None = Field( + default=None, + description=( + "The preset that contributed this exporter. Per-request dynamic OTLP " + "credentials are applied only to the exporter whose owner matches the " + "credential source, so one tenant's vendor key never lands on a " + "different backend's exporter." + ), + ) options: dict[str, str] | None = Field( default=None, description=( diff --git a/litellm/integrations/otel/plumbing/routing.py b/litellm/integrations/otel/plumbing/routing.py index 4d0943a263a..1f2f1b202d9 100644 --- a/litellm/integrations/otel/plumbing/routing.py +++ b/litellm/integrations/otel/plumbing/routing.py @@ -88,13 +88,23 @@ class TenantTracerCache: return get_tracer(provider, self._tracer_name) def _config_with_headers(self, headers: Mapping[str, str]) -> OpenTelemetryV2Config: - """Clone the config, replacing OTLP exporter headers with ``headers``.""" + """Clone the config, stamping ``headers`` onto the credential's own exporter. + + ``headers`` are the per-request credentials of ``self._callback_name`` (the + integration that built this cache), so they apply only to the exporter that + integration contributed (``spec.owner``). A request that carries one + tenant's Arize key must never rewrite the headers of a co-configured + Langfuse or self-hosted collector exporter, which would leak that key to a + different backend. + """ header_str = ",".join(f"{key}={value}" for key, value in headers.items()) + header_update: dict[str, str] = {"headers": header_str} exporters = [ ( - spec - if spec.kind.lower() in _NON_OTLP_KINDS - else spec.model_copy(update={"headers": header_str}) + spec.model_copy(update=header_update) + if spec.owner == self._callback_name + and spec.kind.lower() not in _NON_OTLP_KINDS + else spec ) for spec in self._config.exporters ] diff --git a/litellm/integrations/otel/presets/agentops.py b/litellm/integrations/otel/presets/agentops.py index 5a12818fd99..7b0783935ac 100644 --- a/litellm/integrations/otel/presets/agentops.py +++ b/litellm/integrations/otel/presets/agentops.py @@ -16,7 +16,11 @@ from pydantic import Field from pydantic_settings import BaseSettings, SettingsConfigDict from litellm._logging import verbose_logger -from litellm.integrations.otel.model.config import ExporterSpec, OpenTelemetryV2Config +from litellm.integrations.otel.model.config import ( + ExporterOwner, + ExporterSpec, + OpenTelemetryV2Config, +) from litellm.integrations.otel.plumbing.providers import register_exporter_factory _AGENTOPS_ENDPOINT = "https://otlp.agentops.cloud/v1/traces" @@ -59,6 +63,7 @@ def agentops_preset( options=( {"api_key": settings.api_key} if settings.api_key else None ), + owner=ExporterOwner.AGENTOPS, ), ], "resource_attributes": { diff --git a/litellm/integrations/otel/presets/arize.py b/litellm/integrations/otel/presets/arize.py index 4df15125f5a..b6af88c6b34 100644 --- a/litellm/integrations/otel/presets/arize.py +++ b/litellm/integrations/otel/presets/arize.py @@ -4,7 +4,11 @@ from pydantic import Field from pydantic_settings import BaseSettings, SettingsConfigDict from litellm.integrations.arize.arize import ArizeLogger as _V1ArizeLogger -from litellm.integrations.otel.model.config import ExporterSpec, OpenTelemetryV2Config +from litellm.integrations.otel.model.config import ( + ExporterOwner, + ExporterSpec, + OpenTelemetryV2Config, +) from litellm.integrations.otel.presets.utils import ensure_mappers from litellm.types.utils import StandardCallbackDynamicParams @@ -34,6 +38,7 @@ def arize_preset( kind=arize_cfg.protocol or "otlp_grpc", endpoint=arize_cfg.endpoint or "https://otlp.arize.com/v1", headers=headers, + owner=ExporterOwner.ARIZE_AX, ), ], "mapper_names": ensure_mappers(base.mapper_names, "openinference"), diff --git a/litellm/integrations/otel/presets/langfuse.py b/litellm/integrations/otel/presets/langfuse.py index 011545384b9..5631da6429f 100644 --- a/litellm/integrations/otel/presets/langfuse.py +++ b/litellm/integrations/otel/presets/langfuse.py @@ -3,7 +3,11 @@ from litellm.integrations.langfuse.langfuse_otel import ( LangfuseOtelLogger as _V1Langfuse, ) -from litellm.integrations.otel.model.config import ExporterSpec, OpenTelemetryV2Config +from litellm.integrations.otel.model.config import ( + ExporterOwner, + ExporterSpec, + OpenTelemetryV2Config, +) from litellm.integrations.otel.presets.utils import ensure_mappers from litellm.types.utils import StandardCallbackDynamicParams @@ -23,6 +27,7 @@ def langfuse_preset( kind=kind, endpoint=cfg.endpoint, headers=cfg.headers, + owner=ExporterOwner.LANGFUSE_OTEL, ), ], "mapper_names": ensure_mappers(base.mapper_names, "langfuse"), diff --git a/litellm/integrations/otel/presets/levo.py b/litellm/integrations/otel/presets/levo.py index 4c4cba982a4..74a95b100cb 100644 --- a/litellm/integrations/otel/presets/levo.py +++ b/litellm/integrations/otel/presets/levo.py @@ -1,7 +1,11 @@ """Levo preset — OTLP/HTTP to a Levo collector with org+workspace headers.""" from litellm.integrations.levo.levo import LevoLogger as _V1Levo -from litellm.integrations.otel.model.config import ExporterSpec, OpenTelemetryV2Config +from litellm.integrations.otel.model.config import ( + ExporterOwner, + ExporterSpec, + OpenTelemetryV2Config, +) def levo_preset( @@ -18,6 +22,7 @@ def levo_preset( kind="otlp_http", endpoint=cfg.endpoint, headers=cfg.otlp_auth_headers, + owner=ExporterOwner.LEVO, ), ], } diff --git a/litellm/integrations/otel/presets/phoenix.py b/litellm/integrations/otel/presets/phoenix.py index 4c2b165ffca..5485b599321 100644 --- a/litellm/integrations/otel/presets/phoenix.py +++ b/litellm/integrations/otel/presets/phoenix.py @@ -6,7 +6,11 @@ from pydantic_settings import BaseSettings, SettingsConfigDict from litellm.integrations.arize.arize_phoenix import ( ArizePhoenixLogger as _V1Phoenix, ) -from litellm.integrations.otel.model.config import ExporterSpec, OpenTelemetryV2Config +from litellm.integrations.otel.model.config import ( + ExporterOwner, + ExporterSpec, + OpenTelemetryV2Config, +) from litellm.integrations.otel.presets.utils import ensure_mappers @@ -37,6 +41,7 @@ def phoenix_preset( kind=cfg.protocol if hasattr(cfg, "protocol") else "otlp_http", endpoint=cfg.endpoint, headers=headers, + owner=ExporterOwner.ARIZE_PHOENIX, ), ], "mapper_names": ensure_mappers(base.mapper_names, "openinference"), diff --git a/litellm/integrations/otel/presets/weave.py b/litellm/integrations/otel/presets/weave.py index 9fc03c84a6d..d22f7641289 100644 --- a/litellm/integrations/otel/presets/weave.py +++ b/litellm/integrations/otel/presets/weave.py @@ -1,6 +1,10 @@ """Weave (W&B) preset.""" -from litellm.integrations.otel.model.config import ExporterSpec, OpenTelemetryV2Config +from litellm.integrations.otel.model.config import ( + ExporterOwner, + ExporterSpec, + OpenTelemetryV2Config, +) from litellm.integrations.otel.presets.utils import ensure_mappers from litellm.integrations.weave.weave_otel import ( _get_weave_authorization_header, @@ -23,6 +27,7 @@ def weave_preset( kind=weave_cfg.protocol or "otlp_http", endpoint=weave_cfg.endpoint, headers=weave_cfg.otlp_auth_headers, + owner=ExporterOwner.WEAVE_OTEL, ), ], # Weave consumes OpenInference + a small Weave-specific overlay. diff --git a/litellm/litellm_core_utils/cloud_storage_security.py b/litellm/litellm_core_utils/cloud_storage_security.py index daa3dc60320..a75d1178d5a 100644 --- a/litellm/litellm_core_utils/cloud_storage_security.py +++ b/litellm/litellm_core_utils/cloud_storage_security.py @@ -15,8 +15,23 @@ BEDROCK_MANAGED_S3_PREFIXES = ( BEDROCK_MANAGED_S3_UPLOAD_PREFIX, BEDROCK_MANAGED_S3_OUTPUT_PREFIX, ) +MANAGED_CLOUD_STORAGE_SCHEMES = ("s3://", "gs://") _MAPPING_PROXY_TYPE: type = type(MappingProxyType({})) + +def is_managed_cloud_storage_uri(file_id: str) -> bool: + """ + True if file_id is a raw cloud-storage object URI (e.g. ``s3://bucket/key``). + + These are internal provider artifacts. On the multi-tenant proxy they must be + retrieved through their managed unified file id so owner/team access is enforced; + a raw URI supplied by a caller bypasses that check. + """ + return isinstance(file_id, str) and file_id.startswith( + MANAGED_CLOUD_STORAGE_SCHEMES + ) + + _SAFE_OBJECT_COMPONENT_PATTERN = re.compile(r"[^A-Za-z0-9._-]+") diff --git a/litellm/litellm_core_utils/get_llm_provider_logic.py b/litellm/litellm_core_utils/get_llm_provider_logic.py index 625f8416517..8a02aa72b00 100644 --- a/litellm/litellm_core_utils/get_llm_provider_logic.py +++ b/litellm/litellm_core_utils/get_llm_provider_logic.py @@ -388,6 +388,9 @@ def get_llm_provider( elif endpoint == "https://api.inference.wandb.ai/v1": custom_llm_provider = "wandb" dynamic_api_key = get_secret_str("WANDB_API_KEY") + elif endpoint == "https://pinstripes.io/v1": + custom_llm_provider = "pinstripes" + dynamic_api_key = get_secret_str("PINSTRIPES_API_KEY") elif endpoint == "https://gigachat.devices.sberbank.ru/api/v1": custom_llm_provider = "gigachat" dynamic_api_key = get_secret_str("GIGACHAT_API_KEY") @@ -646,7 +649,7 @@ def _get_openai_compatible_provider_info( api_base, dynamic_api_key, ) = litellm.BedrockMantleChatConfig()._get_openai_compatible_provider_info( - api_base, api_key, litellm_params=litellm_params + api_base, api_key, litellm_params=litellm_params, model=model ) elif custom_llm_provider == "nvidia_nim": # nvidia_nim is openai compatible, we just need to set this to custom_openai and have the api_base be https://api.endpoints.anyscale.com/v1 diff --git a/litellm/litellm_core_utils/health_check_helpers.py b/litellm/litellm_core_utils/health_check_helpers.py index 9e972f1910b..5a29ea73a74 100644 --- a/litellm/litellm_core_utils/health_check_helpers.py +++ b/litellm/litellm_core_utils/health_check_helpers.py @@ -44,8 +44,8 @@ class HealthCheckHelpers: model_params["litellm_logging_obj"] = litellm_logging_obj model_params["fallbacks"] = fallback_models model_params["max_tokens"] = model_params.get( - "max_tokens", 10 - ) # gpt-5-nano throws errors for max_tokens=1 + "max_tokens", 16 + ) # GPT-5 models require max_output_tokens >= 16 await acompletion(**model_params) return {} diff --git a/litellm/litellm_core_utils/litellm_logging.py b/litellm/litellm_core_utils/litellm_logging.py index e0102a60994..e05c8b3577a 100644 --- a/litellm/litellm_core_utils/litellm_logging.py +++ b/litellm/litellm_core_utils/litellm_logging.py @@ -2980,7 +2980,12 @@ class Logging(LiteLLMLoggingBaseClass): ) self.model_call_details["end_time"] = end_time self.model_call_details.setdefault("original_response", None) - self.model_call_details["response_cost"] = 0 + # A stream interrupted mid-flight still billed the provider for the + # chunks already delivered; the router stashes that recovered usage as + # ``combined_usage_object`` and pre-computes its cost, so preserve it + # here instead of zeroing the spend on an otherwise-failed request. + if self.model_call_details.get("combined_usage_object") is None: + self.model_call_details["response_cost"] = 0 if hasattr(exception, "headers") and isinstance(exception.headers, dict): self.model_call_details.setdefault("litellm_params", {}) diff --git a/litellm/litellm_core_utils/streaming_handler.py b/litellm/litellm_core_utils/streaming_handler.py index 888a9658396..d3330c3dcec 100644 --- a/litellm/litellm_core_utils/streaming_handler.py +++ b/litellm/litellm_core_utils/streaming_handler.py @@ -2290,6 +2290,7 @@ class CustomStreamWrapper: litellm.request_timeout ) if self.logging_obj is not None: + self._record_partial_usage_for_failure() ## LOGGING threading.Thread( target=self.logging_obj.failure_handler, @@ -2303,6 +2304,7 @@ class CustomStreamWrapper: except Exception as e: traceback_exception = traceback.format_exc() if self.logging_obj is not None: + self._record_partial_usage_for_failure() ## LOGGING threading.Thread( target=self.logging_obj.failure_handler, @@ -2314,6 +2316,33 @@ class CustomStreamWrapper: ) self._handle_stream_fallback_error(e) + def _record_partial_usage_for_failure(self) -> None: + """ + A stream that breaks mid-flight still billed the provider for the chunks + already delivered. Recover that partial usage from the chunks seen so + far and stash it, with its cost, on the logging object so the failure + handler records the real partial spend instead of zero. A request that + later recovers via a router fallback overwrites this with the combined + success log on the same request id, so this never double counts. + """ + if self.logging_obj is None or not self.chunks: + return + try: + partial_response = litellm.stream_chunk_builder(chunks=self.chunks) + usage = cast(Optional[Usage], getattr(partial_response, "usage", None)) + if usage is None: + return + self.logging_obj.model_call_details["combined_usage_object"] = usage + self.logging_obj.model_call_details["response_cost"] = ( + self.logging_obj._response_cost_calculator(result=partial_response) + or 0.0 + ) + except Exception as recover_error: + verbose_logger.debug( + "could not recover partial usage for interrupted stream: %s", + recover_error, + ) + def _handle_stream_fallback_error(self, e: Exception) -> "NoReturn": """ Common error handling for both __next__ and __anext__. diff --git a/litellm/llms/anthropic/experimental_pass_through/adapters/transformation.py b/litellm/llms/anthropic/experimental_pass_through/adapters/transformation.py index bf425637b56..75a8acdfcc3 100644 --- a/litellm/llms/anthropic/experimental_pass_through/adapters/transformation.py +++ b/litellm/llms/anthropic/experimental_pass_through/adapters/transformation.py @@ -859,7 +859,17 @@ class LiteLLMAnthropicMessagesAdapter: """ new_tools: List[ChatCompletionToolParam] = [] tool_name_mapping: Dict[str, str] = {} - mapped_tool_params = ["name", "input_schema", "description", "cache_control"] + # "type" is the Anthropic tool type (e.g. "custom"); it must not be + # merged into the OpenAI function `parameters` schema below, or it + # overwrites the real parameters.type ("object") and the provider + # rejects the request. See #30557. + mapped_tool_params = [ + "name", + "input_schema", + "description", + "cache_control", + "type", + ] for idx, tool in enumerate(tools): # Check if this is an Anthropic-native tool that should be kept as-is diff --git a/litellm/llms/bedrock/files/handler.py b/litellm/llms/bedrock/files/handler.py index ecf157e12ee..b6aae2159c1 100644 --- a/litellm/llms/bedrock/files/handler.py +++ b/litellm/llms/bedrock/files/handler.py @@ -1,8 +1,6 @@ import asyncio -import base64 -import os -from types import MappingProxyType -from typing import Any, Coroutine, Mapping, Optional, Tuple, Union, cast +from collections.abc import Mapping +from typing import Any, Coroutine, Optional, Tuple, Union import httpx @@ -17,7 +15,6 @@ from litellm.types.llms.openai import ( FileContentRequest, HttpxBinaryResponseContent, ) -from litellm.types.utils import SpecialEnums from ..base_aws_llm import BaseAWSLLM @@ -37,40 +34,9 @@ class BedrockFilesHandler(BaseAWSLLM): ) def _extract_s3_uri_from_file_id(self, file_id: str) -> str: - """ - Extract S3 URI from encoded file ID. + from .transformation import extract_s3_uri_from_file_id - The file ID can be in two formats: - 1. Base64-encoded unified file ID containing: llm_output_file_id,s3://bucket/path - 2. Direct S3 URI: s3://bucket/litellm-managed-prefix/path - - Args: - file_id: Encoded file ID or direct S3 URI - - Returns: - S3 URI (e.g., "s3://bucket-name/path/to/file") - """ - # First, try to decode if it's a base64-encoded unified file ID - try: - # Add padding if needed - padded = file_id + "=" * (-len(file_id) % 4) - decoded = base64.urlsafe_b64decode(padded).decode() - - # Check if it's a unified file ID format - if decoded.startswith(SpecialEnums.LITELM_MANAGED_FILE_ID_PREFIX.value): - # Extract llm_output_file_id from the decoded string - if "llm_output_file_id," in decoded: - s3_uri = decoded.split("llm_output_file_id,")[1].split(";")[0] - return s3_uri - except Exception: - pass - - # If not base64 encoded or doesn't contain llm_output_file_id, accept only - # explicit S3 URIs. Bucket and key validation happens before any S3 call. - if file_id.startswith("s3://"): - return file_id - - raise ValueError("file_id must be a managed LiteLLM S3 file id") + return extract_s3_uri_from_file_id(file_id) def _parse_s3_uri( self, @@ -95,26 +61,12 @@ class BedrockFilesHandler(BaseAWSLLM): allow_legacy_cloud_file_ids=allow_legacy_cloud_file_ids, ) - def _get_configured_s3_bucket_name(self, litellm_params: dict) -> str: - trusted_model_credentials = litellm_params.get( - "_litellm_internal_model_credentials" - ) - bucket_name = None - if isinstance(trusted_model_credentials, type(MappingProxyType({}))): - trusted_model_credentials_mapping = cast( - Mapping[str, Any], trusted_model_credentials - ) - candidate_bucket_name = trusted_model_credentials_mapping.get( - "s3_bucket_name" - ) - if isinstance(candidate_bucket_name, str): - bucket_name = candidate_bucket_name - bucket_name = bucket_name or os.getenv("AWS_S3_BUCKET_NAME") - if not bucket_name: - raise ValueError( - "S3 bucket_name is required. Set 's3_bucket_name' in proxy config or AWS_S3_BUCKET_NAME for Bedrock file content retrieval." - ) - return bucket_name + def _get_configured_s3_bucket_name( + self, litellm_params: Mapping[str, object] + ) -> str: + from .transformation import get_configured_s3_bucket_name + + return get_configured_s3_bucket_name(litellm_params) async def afile_content( self, diff --git a/litellm/llms/bedrock/files/transformation.py b/litellm/llms/bedrock/files/transformation.py index cec2e934af8..6cfaa88275d 100644 --- a/litellm/llms/bedrock/files/transformation.py +++ b/litellm/llms/bedrock/files/transformation.py @@ -1,23 +1,37 @@ +import base64 import json import os import time -from typing import Any, Dict, List, Optional, Tuple, Union +from collections.abc import Mapping, MutableMapping +from types import MappingProxyType +from typing import ( + Any, + Dict, + List, + Optional, + Tuple, + Union, +) from urllib.parse import unquote import httpx from httpx import Headers, Response from openai.types.file_deleted import FileDeleted +from pydantic import BaseModel, ConfigDict from litellm._logging import verbose_logger from litellm._uuid import uuid from litellm.files.utils import FilesAPIUtils from litellm.litellm_core_utils.cloud_storage_security import ( BEDROCK_MANAGED_S3_BATCH_PREFIX, + BEDROCK_MANAGED_S3_PREFIXES, BEDROCK_MANAGED_S3_UPLOAD_PREFIX, build_managed_cloud_object_name, encode_s3_object_key_for_url, sanitize_cloud_object_component, + should_allow_legacy_cloud_file_ids, split_configured_cloud_bucket_name, + validate_managed_cloud_file_id, ) from litellm.litellm_core_utils.prompt_templates.common_utils import extract_file_data from litellm.llms.base_llm.chat.transformation import BaseLLMException @@ -28,18 +42,98 @@ from litellm.llms.base_llm.files.transformation import ( from litellm.types.llms.openai import ( AllMessageValues, CreateFileRequest, + FileContentRequest, FileTypes, HttpxBinaryResponseContent, OpenAICreateFileRequestOptionalParams, OpenAIFileObject, PathLike, ) -from litellm.types.utils import ExtractedFileData, LlmProviders +from litellm.types.utils import ExtractedFileData, LlmProviders, SpecialEnums from litellm.utils import get_llm_provider from ..base_aws_llm import BaseAWSLLM from ..common_utils import BedrockError +# litellm_params key used to hand the SigV4-signed GET headers from +# `transform_file_content_request` to `validate_environment` (the only hook +# the shared file-content HTTP handler exposes for setting request headers). +# Same pattern as the `upload_url` handoff in `transform_create_file_request`. +S3_SIGNED_GET_HEADERS_PARAM = "_s3_signed_get_headers" + + +class _BedrockS3RequestParams(BaseModel): + """Typed view of the credential/region params the S3 GetObject path reads.""" + + model_config = ConfigDict(extra="ignore") + + aws_access_key_id: str | None = None + aws_secret_access_key: str | None = None + aws_session_token: str | None = None + aws_region_name: str | None = None + aws_session_name: str | None = None + aws_profile_name: str | None = None + aws_role_name: str | None = None + aws_web_identity_token: str | None = None + aws_sts_endpoint: str | None = None + s3_region_name: str | None = None + s3_endpoint_url: str | None = None + + +class _TrustedS3ModelCredentials(BaseModel): + """The S3 bucket the server trusts file ids against, from the deployment snapshot.""" + + model_config = ConfigDict(extra="ignore") + + s3_bucket_name: str | None = None + + +def extract_s3_uri_from_file_id(file_id: str) -> str: + """ + Resolve a Bedrock file id to its S3 URI. + + Accepts either a base64-encoded LiteLLM unified file id (whose decoded + form carries `llm_output_file_id,s3://...`) or a direct `s3://` URI. + """ + try: + padded = file_id + "=" * (-len(file_id) % 4) + decoded = base64.urlsafe_b64decode(padded).decode() + + if decoded.startswith(SpecialEnums.LITELM_MANAGED_FILE_ID_PREFIX.value): + if "llm_output_file_id," in decoded: + return decoded.split("llm_output_file_id,")[1].split(";")[0] + except Exception: + pass + + if file_id.startswith("s3://"): + return file_id + + raise ValueError("file_id must be a managed LiteLLM S3 file id") + + +def get_configured_s3_bucket_name(litellm_params: Mapping[str, object]) -> str: + """ + Resolve the server-configured S3 bucket for Bedrock file operations. + + Only trusts the immutable server-side credential snapshot or the + environment; never a request-supplied param, since the bucket is what + `validate_managed_cloud_file_id` checks file ids against. + """ + trusted_model_credentials = litellm_params.get( + "_litellm_internal_model_credentials" + ) + bucket_name: str | None = None + if isinstance(trusted_model_credentials, MappingProxyType): + snapshot: dict[str, object] = {} + snapshot.update(trusted_model_credentials) # any-ok: untyped snapshot + bucket_name = _TrustedS3ModelCredentials.model_validate(snapshot).s3_bucket_name + bucket_name = bucket_name or os.getenv("AWS_S3_BUCKET_NAME") + if not bucket_name: + raise ValueError( + "S3 bucket_name is required. Set 's3_bucket_name' in proxy config or AWS_S3_BUCKET_NAME for Bedrock file content retrieval." + ) + return bucket_name + class BedrockFilesConfig(BaseAWSLLM, BaseFilesConfig): """ @@ -63,16 +157,21 @@ class BedrockFilesConfig(BaseAWSLLM, BaseFilesConfig): def validate_environment( self, - headers: dict, + headers: MutableMapping[str, object], model: str, messages: List[AllMessageValues], optional_params: dict, - litellm_params: dict, - api_key: Optional[str] = None, - api_base: Optional[str] = None, + litellm_params: MutableMapping[str, object], + api_key: str | None = None, + api_base: str | None = None, ) -> dict: - # No additional headers needed for S3 uploads - AWS credentials handled by BaseAWSLLM - return headers + result: dict[str, object] = {} + result.update(headers) + signed_headers = litellm_params.pop(S3_SIGNED_GET_HEADERS_PARAM, None) + if isinstance(signed_headers, Mapping): + result.update(signed_headers) # any-ok: untyped handoff headers + # otherwise no extra headers - AWS credentials are handled by BaseAWSLLM + return result def _get_content_from_openai_file(self, openai_file_content: FileTypes) -> str: """ @@ -927,23 +1026,114 @@ class BedrockFilesConfig(BaseAWSLLM, BaseFilesConfig): def transform_file_content_request( self, - file_content_request, - optional_params: dict, - litellm_params: dict, - ) -> tuple[str, dict]: - raise NotImplementedError( - "BedrockFilesConfig does not support file content retrieval" + file_content_request: FileContentRequest, + optional_params: Mapping[str, object], + litellm_params: MutableMapping[str, object], + ) -> tuple[str, dict[str, str]]: + """ + Build a SigV4-signed S3 GetObject request for a Bedrock batch file. + + Bedrock batch file ids are `s3://bucket/key` URIs (or unified ids + that decode to one); the bucket and key are validated against the + server-configured bucket before any request is signed. + """ + file_id = file_content_request.get("file_id") + if not file_id: + raise ValueError("file_id is required for Bedrock file content retrieval") + + s3_uri = extract_s3_uri_from_file_id(file_id) + bucket_name, object_key = validate_managed_cloud_file_id( + file_id=s3_uri, + scheme="s3://", + configured_bucket_name=get_configured_s3_bucket_name(litellm_params), + allowed_object_prefixes=BEDROCK_MANAGED_S3_PREFIXES, + allow_legacy_cloud_file_ids=should_allow_legacy_cloud_file_ids( + litellm_params + ), ) + # The shared file-content handler passes optional_params={}, so AWS + # credentials/region arrive via litellm_params here (unlike the upload + # path). s3_region_name wins over aws_region_name, same priority as + # get_complete_file_url above. + merged_params: dict[str, object] = {} + merged_params.update(litellm_params) + merged_params.update(optional_params) + request_params = _BedrockS3RequestParams.model_validate(merged_params) + + region_preference = ( + request_params.s3_region_name or request_params.aws_region_name + ) + region_params: dict[str, str | None] = {"aws_region_name": region_preference} + aws_region_name = self._get_aws_region_name( + optional_params=region_params, model="" + ) + + s3_endpoint_url = ( + request_params.s3_endpoint_url + or f"https://s3.{aws_region_name}.amazonaws.com" + ).rstrip("/") + url = f"{s3_endpoint_url}/{bucket_name}/{encode_s3_object_key_for_url(object_key)}" + + litellm_params[S3_SIGNED_GET_HEADERS_PARAM] = self._sign_s3_get_request( + api_base=url, + aws_region_name=aws_region_name, + request_params=request_params, + ) + return url, {} + + def _sign_s3_get_request( + self, + api_base: str, + aws_region_name: str, + request_params: _BedrockS3RequestParams, + ) -> dict[str, str]: + """ + SigV4-sign an S3 GetObject request, mirroring `_sign_s3_request` (PUT). + """ + try: + import hashlib + + from botocore.auth import SigV4Auth + from botocore.awsrequest import AWSRequest + except ImportError: + raise ImportError("Missing boto3 to call bedrock. Run 'pip install boto3'.") + + credentials = self.get_credentials( # any-ok: boto3 Credentials is untyped + aws_access_key_id=request_params.aws_access_key_id, + aws_secret_access_key=request_params.aws_secret_access_key, + aws_session_token=request_params.aws_session_token, + aws_region_name=aws_region_name, + aws_session_name=request_params.aws_session_name, + aws_profile_name=request_params.aws_profile_name, + aws_role_name=request_params.aws_role_name, + aws_web_identity_token=request_params.aws_web_identity_token, + aws_sts_endpoint=request_params.aws_sts_endpoint, + ) + + empty_body_hash = hashlib.sha256(b"").hexdigest() + aws_request = AWSRequest( # any-ok: botocore AWSRequest is untyped + method="GET", + url=api_base, + headers={"x-amz-content-sha256": empty_body_hash}, + ) + auth = SigV4Auth(credentials, "s3", aws_region_name) # any-ok: botocore untyped + auth.add_auth(aws_request) # any-ok: botocore request mutation is untyped + return dict(aws_request.headers) # any-ok: botocore headers are untyped + def transform_file_content_response( self, raw_response: httpx.Response, logging_obj: LiteLLMLoggingObj, litellm_params: dict, ) -> HttpxBinaryResponseContent: - raise NotImplementedError( - "BedrockFilesConfig does not support file content retrieval" - ) + if raw_response.status_code >= 400: + raise BedrockError( + status_code=raw_response.status_code, + message=raw_response.text, + headers=raw_response.headers, + ) + return HttpxBinaryResponseContent(response=raw_response) class BedrockJsonlFilesTransformation: diff --git a/litellm/llms/bedrock_mantle/chat/transformation.py b/litellm/llms/bedrock_mantle/chat/transformation.py index 1504e89c58e..f688cea10f1 100644 --- a/litellm/llms/bedrock_mantle/chat/transformation.py +++ b/litellm/llms/bedrock_mantle/chat/transformation.py @@ -23,6 +23,7 @@ from litellm.secret_managers.main import get_secret_str from litellm.types.llms.openai import AllMessageValues from litellm.types.router import GenericLiteLLMParams +from ..common_utils import mantle_base_segment from ...openai_like.chat.transformation import OpenAILikeChatConfig @@ -48,6 +49,7 @@ class BedrockMantleChatConfig(BedrockMantleAuthMixin, OpenAILikeChatConfig): api_base: Optional[str], api_key: Optional[str], litellm_params: Optional[GenericLiteLLMParams] = None, + model: str | None = None, ) -> Tuple[Optional[str], Optional[str]]: region = ( (litellm_params.aws_region_name if litellm_params else None) @@ -57,10 +59,13 @@ class BedrockMantleChatConfig(BedrockMantleAuthMixin, OpenAILikeChatConfig): or BEDROCK_MANTLE_DEFAULT_REGION ) BaseAWSLLM._validate_aws_region_name(region) + # The base path segment is data-driven per model (use_openai_responses_path + # flag): gemma-4-* and gpt-5.x are served on /openai/v1, everything else on + # /v1. An explicit api_base still wins over the derived default. api_base = ( api_base or get_secret_str("BEDROCK_MANTLE_API_BASE") - or f"https://bedrock-mantle.{region}.api.aws/v1" + or f"https://bedrock-mantle.{region}.api.aws/{mantle_base_segment(model, litellm.model_cost)}" ) dynamic_api_key = self._resolve_bearer_token(api_key) return api_base, dynamic_api_key diff --git a/litellm/llms/bedrock_mantle/common_utils.py b/litellm/llms/bedrock_mantle/common_utils.py index 8c092f345d9..d517ab940ce 100644 --- a/litellm/llms/bedrock_mantle/common_utils.py +++ b/litellm/llms/bedrock_mantle/common_utils.py @@ -1,5 +1,4 @@ -""" -Shared auth and region resolution for the Amazon Bedrock Mantle backends. +"""Shared auth, region resolution, and routing helpers for the Amazon Bedrock Mantle provider. Mantle authenticates with a Bearer token when one is available (litellm_params.api_key, BEDROCK_MANTLE_API_KEY, or the standard @@ -7,6 +6,10 @@ AWS_BEARER_TOKEN_BEDROCK); otherwise it falls back to AWS SigV4 (service "bedrock") over the standard credential chain (IAM role / access key / profile / web identity). The Chat Completions and Responses backends share this behaviour through BedrockMantleAuthMixin so the two paths can never drift apart. + +The two routing helpers (mantle_supports_responses, mantle_base_segment) are +pure functions of (model, model_cost) so they can be unit-tested without patching +global state. """ import re @@ -72,13 +75,9 @@ class BedrockMantleAuthMixin: ) -> Tuple[dict, bytes | None]: bearer = self._resolve_bearer_token(api_key) if not bearer: - # SigV4 path. Pin the credential-scope region to the region of the actual - # signing URL so the SigV4 scope and the URL host can never disagree, even - # when a stale api_base and aws_region_name point at different regions. - # Fall back to _resolve_region only for custom proxy hosts that do not - # match the standard Mantle URL pattern. Also drop any caller Authorization - # so _sign_request's restore-original-Authorization step cannot override - # the SigV4 header. + # Pin the credential-scope region to the region of the actual signing URL + # so the SigV4 scope and URL host can never disagree, even when a stale + # api_base and aws_region_name point at different regions. host_match = MANTLE_HOST_RE.match(api_base.rstrip("/")) optional_params = { **optional_params, @@ -113,3 +112,36 @@ class BedrockMantleAuthMixin: "or pass api_key for Bearer auth, or provide AWS credentials " "(IAM role / access key / profile / web identity) for SigV4." ) from e + + +def mantle_supports_responses(model: str | None, model_cost: dict) -> bool: + """Whether a Bedrock Mantle model can serve the native Responses API. + + Purely data-driven from the model's price-map capability signal -- either + /v1/responses in supported_endpoints, or mode=responses -- both overridable + via register_model and proxy model_info, so onboarding a model is a JSON + change, never a code change. There is deliberately NO model-name match here: + capability is per-model, not per-family (openai.gpt-oss-120b supports + Responses while openai.gpt-oss-safeguard-120b does not, despite sharing the + gpt-oss substring), so a substring gate would be wrong. A model absent from + model_cost simply has no signal and returns False (chat-completions emulation). + """ + entry = model_cost.get(f"bedrock_mantle/{model}", {}) + if "/v1/responses" in (entry.get("supported_endpoints") or []): + return True + return entry.get("mode") == "responses" + + +def mantle_base_segment(model: str | None, model_cost: dict) -> str: + """Return the base path segment for a Bedrock Mantle model's OpenAI surface. + + Data-driven from the model's price-map use_openai_responses_path flag + (overridable via register_model / proxy model_info). Per the AWS model cards, + gpt-5.x and the google gemma-4-* family carry that flag and are served on the + /openai/v1 base (.../openai/v1/responses and .../openai/v1/chat/completions); + every other model including gpt-oss uses the standard /v1 base. The segment is + the base for the model's whole OpenAI-compatible surface, so both the chat and + responses configs derive from it -- there is no separate model-name rule. + """ + entry = model_cost.get(f"bedrock_mantle/{model}", {}) + return "openai/v1" if entry.get("use_openai_responses_path") is True else "v1" diff --git a/litellm/llms/openai_like/providers.json b/litellm/llms/openai_like/providers.json index 0dda047d1ca..24943563937 100644 --- a/litellm/llms/openai_like/providers.json +++ b/litellm/llms/openai_like/providers.json @@ -159,5 +159,14 @@ "max_completion_tokens": "max_tokens" }, "supported_endpoints": ["/v1/chat/completions", "/v1/responses"] + }, + "pinstripes": { + "base_url": "https://pinstripes.io/v1", + "api_key_env": "PINSTRIPES_API_KEY", + "api_base_env": "PINSTRIPES_API_BASE", + "param_mappings": { + "max_completion_tokens": "max_tokens" + }, + "supported_endpoints": ["/v1/chat/completions", "/v1/responses", "/v1/embeddings"] } } diff --git a/litellm/llms/tinyfish/search/__init__.py b/litellm/llms/tinyfish/search/__init__.py new file mode 100644 index 00000000000..9777e735aac --- /dev/null +++ b/litellm/llms/tinyfish/search/__init__.py @@ -0,0 +1,3 @@ +from litellm.llms.tinyfish.search.transformation import TinyfishSearchConfig + +__all__ = ["TinyfishSearchConfig"] diff --git a/litellm/llms/tinyfish/search/transformation.py b/litellm/llms/tinyfish/search/transformation.py new file mode 100644 index 00000000000..c4949380e3a --- /dev/null +++ b/litellm/llms/tinyfish/search/transformation.py @@ -0,0 +1,164 @@ +""" +TinyFish Search API. +Endpoint: GET https://api.search.tinyfish.ai +Docs: https://docs.tinyfish.ai/search-api +""" + +from __future__ import annotations + +from typing import Literal, TypedDict +from urllib.parse import urlencode + +import httpx +from pydantic import BaseModel, TypeAdapter, ValidationError + +from litellm.litellm_core_utils.litellm_logging import Logging as LiteLLMLoggingObj +from litellm.llms.base_llm.search.transformation import ( + BaseSearchConfig, + SearchResponse, + SearchResult, +) +from litellm.secret_managers.main import get_secret_str + + +class _TinyfishSearchRequestRequired(TypedDict): + query: str + + +class TinyfishSearchRequest(_TinyfishSearchRequestRequired, total=False): + location: str + language: str + page: int + include_thumbnail: bool + max_results: int + + +class _TinyfishResultItem(BaseModel, frozen=True): + title: str = "" + url: str = "" + snippet: str = "" + + +class _TinyfishApiResponse(BaseModel, frozen=True): + results: tuple[_TinyfishResultItem, ...] = () + + +_UrlEncodableParams = TypeAdapter(dict[str, str | int | bool]) +_StrList = TypeAdapter(list[str]) +_StrFrozenSet = TypeAdapter(frozenset[str]) + +_TINYFISH_PARAMS_KEY = "_tinyfish_params" + + +class TinyfishSearchConfig(BaseSearchConfig): + TINYFISH_API_BASE = "https://api.search.tinyfish.ai" + + @staticmethod + def ui_friendly_name() -> str: + return "TinyFish" + + def get_http_method(self) -> Literal["GET", "POST"]: + return "GET" + + def validate_environment( + self, + headers: dict[str, str], + api_key: str | None = None, + api_base: str | None = None, + **kwargs: object, + ) -> dict[str, str]: + resolved_key = api_key or get_secret_str("TINYFISH_API_KEY") + if not resolved_key: + raise ValueError( + "TINYFISH_API_KEY is not set. Set `TINYFISH_API_KEY` environment variable." + ) + return {**headers, "X-API-Key": resolved_key, "Accept": "application/json"} + + def get_complete_url( + self, + api_base: str | None, + optional_params: dict[str, object], + data: dict[str, object] | list[dict[str, object]] | None = None, + **kwargs: object, + ) -> str: + resolved_base = ( + api_base or get_secret_str("TINYFISH_API_BASE") or self.TINYFISH_API_BASE + ) + if isinstance(data, dict) and _TINYFISH_PARAMS_KEY in data: + validated_params = _UrlEncodableParams.validate_python( + data[_TINYFISH_PARAMS_KEY] + ) + return f"{resolved_base}?{urlencode(validated_params, doseq=True)}" + return resolved_base + + def transform_search_request( + self, + query: str | list[str], + optional_params: dict[str, object], + **kwargs: object, + ) -> dict[str, object]: + resolved_query = " ".join(query) if isinstance(query, list) else query + + request_data: TinyfishSearchRequest = {"query": resolved_query} + + country = optional_params.get("country") + if isinstance(country, str): + request_data["location"] = country + + raw_max = optional_params.get("max_results") + if isinstance(raw_max, (int, float, str)): + request_data["max_results"] = max(1, min(int(raw_max), 20)) + + try: + domains = _StrList.validate_python( + optional_params.get("search_domain_filter") + ) + except (ValidationError, TypeError): + domains = [] + if domains: + request_data["query"] = _append_domain_filters( + request_data["query"], domains + ) + + result_data: dict[str, object] = dict(request_data) + + raw_supported: object = ( + self.get_supported_perplexity_optional_params() # any-ok: base class returns bare set + ) + supported_perplexity = _StrFrozenSet.validate_python(raw_supported) + for param, value in optional_params.items(): + if param not in supported_perplexity and param not in result_data: + result_data[param] = value + + return {_TINYFISH_PARAMS_KEY: result_data} + + def transform_search_response( + self, + raw_response: httpx.Response, + logging_obj: LiteLLMLoggingObj | None, + **kwargs: object, + ) -> SearchResponse: + raw_json: object = raw_response.json() # any-ok: httpx Response.json() -> Any + parsed = _TinyfishApiResponse.model_validate(raw_json) + + max_results_str: str = "20" + if raw_response.request: + raw_param: object = ( + raw_response.request.url.params.get( # any-ok: httpx QueryParams.get() -> Any + "max_results", "20" + ) + ) + max_results_str = str(raw_param) + max_results: int = min(int(max_results_str), 20) + + results = [ + SearchResult(title=item.title, url=item.url, snippet=item.snippet) + for item in parsed.results[:max_results] + ] + + return SearchResponse(results=results, object="search") + + +def _append_domain_filters(query: str, domains: list[str]) -> str: + domain_clauses = " OR ".join(f"site:{d}" for d in domains) + return f"({query}) ({domain_clauses})" diff --git a/litellm/llms/vertex_ai/common_utils.py b/litellm/llms/vertex_ai/common_utils.py index 85c23d8603c..5028c0cf5c8 100644 --- a/litellm/llms/vertex_ai/common_utils.py +++ b/litellm/llms/vertex_ai/common_utils.py @@ -271,7 +271,7 @@ def supports_response_json_schema(model: str) -> bool: # Gemini 2.0+ and 2.5+ models support responseJsonSchema # Pattern matches: gemini-2.0-*, gemini-2.5-*, gemini-3-*, etc. - gemini_2_plus_pattern = re.compile(r"gemini-([2-9]|[1-9]\d+)\.") + gemini_2_plus_pattern = re.compile(r"gemini-(?:[2-9]|[1-9]\d+)(?:\.|\-)") return bool(gemini_2_plus_pattern.search(model_lower)) diff --git a/litellm/model_prices_and_context_window_backup.json b/litellm/model_prices_and_context_window_backup.json index 39d612f252d..7a5f8b9e1e3 100644 --- a/litellm/model_prices_and_context_window_backup.json +++ b/litellm/model_prices_and_context_window_backup.json @@ -42383,6 +42383,7 @@ "max_output_tokens": 32768, "max_tokens": 32768, "mode": "chat", + "supported_endpoints": ["/v1/chat/completions", "/v1/responses"], "supports_function_calling": true, "supports_parallel_function_calling": true, "supports_reasoning": true, @@ -42397,6 +42398,7 @@ "max_output_tokens": 32768, "max_tokens": 32768, "mode": "chat", + "supported_endpoints": ["/v1/chat/completions", "/v1/responses"], "supports_function_calling": true, "supports_parallel_function_calling": true, "supports_reasoning": true, @@ -42411,6 +42413,7 @@ "max_output_tokens": 65536, "max_tokens": 65536, "mode": "chat", + "supported_endpoints": ["/v1/chat/completions"], "supports_function_calling": true, "supports_reasoning": true, "supports_response_schema": true, @@ -42424,6 +42427,7 @@ "max_output_tokens": 65536, "max_tokens": 65536, "mode": "chat", + "supported_endpoints": ["/v1/chat/completions"], "supports_function_calling": true, "supports_reasoning": true, "supports_response_schema": true, @@ -42477,6 +42481,8 @@ "max_output_tokens": 256000, "max_tokens": 256000, "mode": "chat", + "use_openai_responses_path": true, + "supported_endpoints": ["/v1/chat/completions", "/v1/responses"], "supports_function_calling": true, "supports_parallel_function_calling": false, "supports_reasoning": true, @@ -42491,6 +42497,8 @@ "max_output_tokens": 256000, "max_tokens": 256000, "mode": "chat", + "use_openai_responses_path": true, + "supported_endpoints": ["/v1/chat/completions", "/v1/responses"], "supports_function_calling": true, "supports_parallel_function_calling": false, "supports_reasoning": true, @@ -42505,6 +42513,8 @@ "max_output_tokens": 128000, "max_tokens": 128000, "mode": "chat", + "use_openai_responses_path": true, + "supported_endpoints": ["/v1/chat/completions", "/v1/responses"], "supports_function_calling": true, "supports_parallel_function_calling": false, "supports_reasoning": true, @@ -42803,6 +42813,19 @@ ], "supports_audio_input": true }, + "soniox/stt-async-v5": { + "litellm_provider": "soniox", + "max_output_tokens": 8000, + "max_tokens": 8000, + "input_cost_per_second": 0.0, + "output_cost_per_second": 0.0000277778, + "mode": "audio_transcription", + "source": "https://soniox.com/pricing", + "supported_endpoints": [ + "/v1/audio/transcriptions" + ], + "supports_audio_input": true + }, "tensormesh/Qwen/Qwen3.5-397B-A17B-FP8": { "litellm_provider": "tensormesh", "mode": "chat", diff --git a/litellm/proxy/auth/auth_checks.py b/litellm/proxy/auth/auth_checks.py index 814346eddf8..6ddf2cfeb20 100644 --- a/litellm/proxy/auth/auth_checks.py +++ b/litellm/proxy/auth/auth_checks.py @@ -61,6 +61,7 @@ from litellm.proxy._types import ( UserAPIKeyAuth, ) from litellm.proxy.auth.route_checks import RouteChecks +from litellm.proxy.spend_tracking.budget_reservation import get_budget_window_start from litellm.proxy.common_utils.cache_pydantic_utils import CacheCodec from litellm.proxy.common_utils.http_parsing_utils import ( _safe_get_request_headers, @@ -725,6 +726,7 @@ async def common_checks( user_spend = await get_current_spend( counter_key=f"spend:user:{user_object.user_id}", fallback_spend=user_object.spend or 0.0, + max_budget=user_budget, ) if math.isfinite(user_budget) and user_spend >= user_budget: raise litellm.BudgetExceededError( @@ -1127,6 +1129,8 @@ async def _check_end_user_budget( end_user_spend = await get_current_spend( counter_key=f"spend:end_user:{end_user_obj.user_id}", fallback_spend=end_user_obj.spend or 0.0, + max_budget=end_user_budget, + fallback_authoritative=True, ) if end_user_spend > end_user_budget: raise litellm.BudgetExceededError( @@ -3615,6 +3619,7 @@ async def _virtual_key_max_budget_check( spend = await get_current_spend( counter_key=counter_key, fallback_spend=fallback_spend, + max_budget=valid_token.max_budget, ) #################################### @@ -3684,6 +3689,10 @@ async def _virtual_key_multi_budget_check( window_spend = await get_current_spend( counter_key=counter_key, fallback_spend=0.0, + max_budget=w["max_budget"], + window_entity_type="Key", + window_entity_id=valid_token.token, + window_start=get_budget_window_start(w), ) if math.isfinite(w["max_budget"]) and window_spend >= w["max_budget"]: raise litellm.BudgetExceededError( @@ -3938,6 +3947,7 @@ async def _check_team_member_budget( team_member_spend = await get_current_spend( counter_key=f"spend:team_member:{valid_token.user_id}:{team_object.team_id}", fallback_spend=team_member_spend, + max_budget=team_member_budget, ) if ( @@ -4023,6 +4033,7 @@ async def _team_max_budget_check( spend = await get_current_spend( counter_key=f"spend:team:{team_object.team_id}", fallback_spend=team_object.spend or 0.0, + max_budget=team_object.max_budget, ) if math.isfinite(team_object.max_budget) and spend > team_object.max_budget: @@ -4072,6 +4083,10 @@ async def _team_multi_budget_check( window_spend = await get_current_spend( counter_key=counter_key, fallback_spend=0.0, + max_budget=w["max_budget"], + window_entity_type="Team", + window_entity_id=team_object.team_id, + window_start=get_budget_window_start(w), ) if math.isfinite(w["max_budget"]) and window_spend >= w["max_budget"]: raise litellm.BudgetExceededError( @@ -4377,6 +4392,7 @@ async def _organization_max_budget_check( org_spend = await get_current_spend( counter_key=f"spend:org:{org_id}", fallback_spend=org_table.spend or 0.0, + max_budget=org_max_budget, ) # Check if organization spend exceeds max budget @@ -4454,6 +4470,8 @@ async def _tag_max_budget_check( tag_spend = await get_current_spend( counter_key=f"spend:tag:{tag_name}", fallback_spend=tag_object.spend or 0.0, + max_budget=tag_object.litellm_budget_table.max_budget, + fallback_authoritative=True, ) if tag_spend <= tag_object.litellm_budget_table.max_budget: continue diff --git a/litellm/proxy/auth/user_api_key_auth.py b/litellm/proxy/auth/user_api_key_auth.py index 6f359e52eeb..00d98a04a78 100644 --- a/litellm/proxy/auth/user_api_key_auth.py +++ b/litellm/proxy/auth/user_api_key_auth.py @@ -1837,6 +1837,7 @@ async def _user_api_key_auth_builder( team_member_spend = await get_current_spend( counter_key=f"spend:team_member:{valid_token.user_id}:{valid_token.team_id}", fallback_spend=team_member_spend, + max_budget=team_member_budget, ) if team_member_spend > team_member_budget: raise litellm.BudgetExceededError( diff --git a/litellm/proxy/common_request_processing.py b/litellm/proxy/common_request_processing.py index 6cb65692099..2ffa5682a39 100644 --- a/litellm/proxy/common_request_processing.py +++ b/litellm/proxy/common_request_processing.py @@ -2542,6 +2542,7 @@ class ProxyBaseLLMRequestProcessing: debug_enabled = verbose_proxy_logger.isEnabledFor(logging.DEBUG) stream_completed = False client_disconnected = False + delivered_chunk = False try: str_so_far = "" async for ( @@ -2558,36 +2559,38 @@ class ProxyBaseLLMRequestProcessing: "async_data_generator: received streaming chunk - %s", chunk ) - if fast_path: - yield serialize_chunk(chunk) - continue + if not fast_path: + chunk = await proxy_logging_obj.async_post_call_streaming_hook( + user_api_key_dict=user_api_key_dict, + response=chunk, + data=request_data, + str_so_far=str_so_far, + ) - chunk = await proxy_logging_obj.async_post_call_streaming_hook( - user_api_key_dict=user_api_key_dict, - response=chunk, - data=request_data, - str_so_far=str_so_far, - ) + if isinstance(chunk, (ModelResponse, ModelResponseStream)): + response_str = litellm.get_response_string(response_obj=chunk) + str_so_far += response_str + elif hasattr(chunk, "model_dump"): + try: + d = chunk.model_dump(mode="json", exclude_none=True) + if isinstance(d, dict): + str_so_far += str(d.get("content", "")) + except Exception: + pass + elif isinstance(chunk, dict): + str_so_far += str(chunk.get("content", "")) - if isinstance(chunk, (ModelResponse, ModelResponseStream)): - response_str = litellm.get_response_string(response_obj=chunk) - str_so_far += response_str - elif hasattr(chunk, "model_dump"): - try: - d = chunk.model_dump(mode="json", exclude_none=True) - if isinstance(d, dict): - str_so_far += str(d.get("content", "")) - except Exception: - pass - elif isinstance(chunk, dict): - str_so_far += str(chunk.get("content", "")) - - model_name = request_data.get("model", "") - chunk = ( - ProxyBaseLLMRequestProcessing._process_chunk_with_cost_injection( + model_name = request_data.get("model", "") + chunk = ProxyBaseLLMRequestProcessing._process_chunk_with_cost_injection( chunk, model_name ) - ) + + # Set before the yield: an async generator suspends at the yield, + # so a GeneratorExit on client disconnect is raised there and any + # statement after the yield never runs. The slow-path hook is + # awaited above, so a cancellation during it still leaves this + # False and refunds. + delivered_chunk = True yield serialize_chunk(chunk) stream_completed = True except (asyncio.CancelledError, GeneratorExit): @@ -2602,6 +2605,14 @@ class ProxyBaseLLMRequestProcessing: user_api_key_dict ) client_disconnected = True + if not delivered_chunk: + from litellm.proxy.spend_tracking.budget_reservation import ( + release_budget_reservation_on_cancel, + ) + + await release_budget_reservation_on_cancel( + getattr(user_api_key_dict, "budget_reservation", None) + ) raise except Exception as e: verbose_proxy_logger.exception( diff --git a/litellm/proxy/common_utils/html_forms/ui_login.py b/litellm/proxy/common_utils/html_forms/ui_login.py index 42cfb592a78..6146672ac21 100644 --- a/litellm/proxy/common_utils/html_forms/ui_login.py +++ b/litellm/proxy/common_utils/html_forms/ui_login.py @@ -10,7 +10,10 @@ url_to_redirect_to += "/login" new_ui_login_url = get_custom_url("", "ui/login") -def build_ui_login_form(show_deprecation_banner: bool = False) -> str: +def build_ui_login_form( + show_deprecation_banner: bool = False, + hide_default_credentials_hint: bool = False, +) -> str: banner_html = ( f"""
Access your LiteLLM Admin UI.
-By default, Username is admin and Password is your set LiteLLM Proxy MASTER_KEY.
Need to set UI credentials or SSO? Check the documentation.
-