scriptoriumadmin/litellm
1
0
Fork 0
mirror of https://github.com/BerriAI/litellm.git synced 2026-09-13 23:11:40 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 101

fix(minimax): reuse shared async HTTP client

Browse source
This commit is contained in:
octo-patch 2026-09-10 12:24:40 +08:00
parent 4b2d8a7ba5
commit 003004fca8
2 changed files with 23 additions and 23 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
litellm/llms/minimax/voice_clone/transformation.py
View file

@ -35,7 +35,7 @@ class VoiceCloneResponse(TypedDict):
class MinimaxVoiceCloneError(BaseLLMException):
"""Error raised when MiniMax rejects an upload or clone request."""
def __init__(self, message: str, status_code: int = 0, headers: Mapping[str, str] | None = None):
def __init__(self, message: str, status_code: int = 0, headers: Mapping[str, str] | None = None) -> None:
super().__init__(message=message, status_code=status_code, headers=headers)

44
litellm/voice_clone/main.py
View file

@ -7,11 +7,13 @@ ID can then be passed to MiniMax text-to-speech calls as the voice value.
import httpx
from litellm.llms.custom_httpx.http_handler import get_async_httpx_client
from litellm.llms.minimax.voice_clone.transformation import (
MinimaxVoiceCloneConfig,
VoiceCloneResponse,
)
from litellm.types.llms.openai import FileTypes
from litellm.types.utils import LlmProviders
def _validate_provider(custom_llm_provider: str | None) -> None:
@ -98,25 +100,23 @@ async def avoice_clone(
upload_files, upload_data = config.transform_upload_request(file=file, purpose=purpose)
config.transform_clone_request(file_id="pending", voice_id=voice_id, model=model)
timeout_value = timeout if timeout is not None else 600.0
owns_client = client is None
http_client = client or httpx.AsyncClient(timeout=timeout_value)
try:
upload_response = await http_client.post(
config.get_complete_url(api_base=api_base, operation="upload"),
headers=headers,
files=upload_files,
data=upload_data,
timeout=timeout_value,
)
file_id = config.transform_upload_response(upload_response)
clone_body = config.transform_clone_request(file_id=file_id, voice_id=voice_id, model=model)
clone_response = await http_client.post(
config.get_complete_url(api_base=api_base, operation="clone"),
headers={**headers, "Content-Type": "application/json"},
json=clone_body,
timeout=timeout_value,
)
return config.transform_clone_response(clone_response, file_id=file_id, model=model)
finally:
if owns_client:
await http_client.aclose()
http_client = client or get_async_httpx_client(
llm_provider=LlmProviders.MINIMAX,
params={"timeout": timeout_value},
)
upload_response = await http_client.post(
config.get_complete_url(api_base=api_base, operation="upload"),
headers=headers,
files=upload_files,
data=upload_data,
timeout=timeout_value,
)
file_id = config.transform_upload_response(upload_response)
clone_body = config.transform_clone_request(file_id=file_id, voice_id=voice_id, model=model)
clone_response = await http_client.post(
config.get_complete_url(api_base=api_base, operation="clone"),
headers={**headers, "Content-Type": "application/json"},
json=clone_body,
timeout=timeout_value,
)
return config.transform_clone_response(clone_response, file_id=file_id, model=model)