From 0f6cc231cff3c060add5634bcca0075d013f3c85 Mon Sep 17 00:00:00 2001 From: dhruvladia-sarvam Date: Tue, 24 Mar 2026 00:06:15 +0530 Subject: [PATCH] removing error wraps and model validation check --- src/pipecat/services/sarvam/llm.py | 25 ++----------------------- 1 file changed, 2 insertions(+), 23 deletions(-) diff --git a/src/pipecat/services/sarvam/llm.py b/src/pipecat/services/sarvam/llm.py index 6085cbb08..5b25e3068 100644 --- a/src/pipecat/services/sarvam/llm.py +++ b/src/pipecat/services/sarvam/llm.py @@ -6,27 +6,19 @@ """Sarvam LLM service implementation using OpenAI-compatible interface.""" -import asyncio -import json from dataclasses import dataclass, field -from typing import Any, Awaitable, Literal, Mapping, Optional, TypeVar +from typing import Literal, Mapping, Optional -import httpx from loguru import logger -from openai import NOT_GIVEN, APITimeoutError, AsyncStream -from openai.types.chat import ChatCompletionChunk +from openai import NOT_GIVEN from pipecat.adapters.services.open_ai_adapter import OpenAILLMInvocationParams -from pipecat.processors.aggregators.llm_context import LLMContext -from pipecat.processors.aggregators.openai_llm_context import OpenAILLMContext from pipecat.services.openai.base_llm import OpenAILLMSettings from pipecat.services.openai.llm import OpenAILLMService from pipecat.services.sarvam._sdk import sdk_headers from pipecat.services.settings import NOT_GIVEN as _NOT_GIVEN from pipecat.services.settings import _NotGiven, is_given -_T = TypeVar("_T") - @dataclass class SarvamLLMSettings(OpenAILLMSettings): @@ -52,7 +44,6 @@ class SarvamLLMService(OpenAILLMService): - request shaping for Sarvam-compatible parameters - Sarvam auth header wiring (``api-subscription-key``) - SDK User-Agent propagation on every API call - - raw Sarvam server error passthrough """ _SUPPORTED_MODELS = frozenset( @@ -216,15 +207,3 @@ class SarvamLLMService(OpenAILLMService): if has_tool_choice and not has_tools: raise ValueError("Sarvam requires non-empty `tools` when `tool_choice` is provided.") - - def _payload_to_message(self, payload: Any) -> str: - if isinstance(payload, dict): - error_obj = payload.get("error") - if isinstance(error_obj, dict) and isinstance(error_obj.get("message"), str): - return error_obj["message"] - if isinstance(payload.get("message"), str): - return payload["message"] - return json.dumps(payload, ensure_ascii=False) - if isinstance(payload, list): - return json.dumps(payload, ensure_ascii=False) - return str(payload)