diff --git a/examples/foundational/39-mcp-stdio.py b/examples/foundational/39-mcp-stdio.py index b6f111044..7a99507da 100644 --- a/examples/foundational/39-mcp-stdio.py +++ b/examples/foundational/39-mcp-stdio.py @@ -70,7 +70,7 @@ class UrlToImageProcessor(FrameProcessor): return data["artObject"]["webImage"]["url"] if "artworks" in data and len(data["artworks"]): return data["artworks"][0]["webImage"]["url"] - except: + except (json.JSONDecodeError, KeyError, TypeError): pass return None diff --git a/examples/foundational/39c-multiple-mcp.py b/examples/foundational/39c-multiple-mcp.py index 4c7bc27d9..a4224b019 100644 --- a/examples/foundational/39c-multiple-mcp.py +++ b/examples/foundational/39c-multiple-mcp.py @@ -72,7 +72,7 @@ class UrlToImageProcessor(FrameProcessor): return data["artObject"]["webImage"]["url"] if "artworks" in data and len(data["artworks"]): return data["artworks"][0]["webImage"]["url"] - except: + except (json.JSONDecodeError, KeyError, TypeError): pass async def run_image_process(self, image_url: str): diff --git a/src/pipecat/adapters/services/bedrock_adapter.py b/src/pipecat/adapters/services/bedrock_adapter.py index ccbbe5e2e..d63c5cf0f 100644 --- a/src/pipecat/adapters/services/bedrock_adapter.py +++ b/src/pipecat/adapters/services/bedrock_adapter.py @@ -209,7 +209,7 @@ class AWSBedrockLLMAdapter(BaseLLMAdapter[AWSBedrockLLMInvocationParams]): tool_result_content = [{"json": content_json}] else: tool_result_content = [{"text": message["content"]}] - except: + except (json.JSONDecodeError, ValueError, AttributeError): tool_result_content = [{"text": message["content"]}] return { diff --git a/src/pipecat/serializers/telnyx.py b/src/pipecat/serializers/telnyx.py index 769244f93..1c0405ade 100644 --- a/src/pipecat/serializers/telnyx.py +++ b/src/pipecat/serializers/telnyx.py @@ -198,7 +198,7 @@ class TelnyxFrameSerializer(FrameSerializer): f"Telnyx call {call_control_id} was already terminated" ) return - except: + except Exception: pass # Fall through to log the raw error # Log other 422 errors diff --git a/src/pipecat/serializers/twilio.py b/src/pipecat/serializers/twilio.py index 72fec4f28..bf92a9043 100644 --- a/src/pipecat/serializers/twilio.py +++ b/src/pipecat/serializers/twilio.py @@ -212,7 +212,7 @@ class TwilioFrameSerializer(FrameSerializer): if error_data.get("code") == 20404: logger.debug(f"Twilio call {call_sid} was already terminated") return - except: + except Exception: pass # Fall through to log the raw error # Log other 404 errors diff --git a/src/pipecat/services/aws/llm.py b/src/pipecat/services/aws/llm.py index bcc5028c4..3cc6c2d58 100644 --- a/src/pipecat/services/aws/llm.py +++ b/src/pipecat/services/aws/llm.py @@ -371,7 +371,7 @@ class AWSBedrockLLMContext(OpenAILLMContext): tool_result_content = [{"json": content_json}] else: tool_result_content = [{"text": message["content"]}] - except: + except (json.JSONDecodeError, ValueError, AttributeError): tool_result_content = [{"text": message["content"]}] return { diff --git a/src/pipecat/services/mcp_service.py b/src/pipecat/services/mcp_service.py index 936e210d2..d4f0807b8 100644 --- a/src/pipecat/services/mcp_service.py +++ b/src/pipecat/services/mcp_service.py @@ -296,10 +296,7 @@ class MCPClient(BaseObject): available_tools = await session.list_tools() tool_schemas: List[FunctionSchema] = [] - try: - logger.debug(f"Found {len(available_tools)} available tools") - except: - pass + logger.debug(f"Found {len(available_tools.tools)} available tools") for tool in available_tools.tools: tool_name = tool.name