diff --git a/src/pipecat/frames/frames.py b/src/pipecat/frames/frames.py index c846bd152..e3b2aab37 100644 --- a/src/pipecat/frames/frames.py +++ b/src/pipecat/frames/frames.py @@ -9,6 +9,7 @@ from typing import Any, List, Mapping, Optional, Tuple from dataclasses import dataclass, field from pipecat.utils.utils import obj_count, obj_id +from pipecat.vad.vad_analyzer import VADParams @dataclass @@ -455,7 +456,7 @@ class FunctionCallResultFrame(DataFrame): function_name: str tool_call_id: str arguments: str - result: any + result: Any @dataclass @@ -463,4 +464,4 @@ class VADParamsUpdateFrame(ControlFrame): """A control frame containing a request to update VAD params. Intended to be pushed upstream from RTVI processor. """ - params: dict + params: VADParams diff --git a/src/pipecat/transports/base_input.py b/src/pipecat/transports/base_input.py index 91052788c..49a685d0e 100644 --- a/src/pipecat/transports/base_input.py +++ b/src/pipecat/transports/base_input.py @@ -23,7 +23,7 @@ from pipecat.frames.frames import ( UserStoppedSpeakingFrame, VADParamsUpdateFrame) from pipecat.transports.base_transport import TransportParams -from pipecat.vad.vad_analyzer import VADAnalyzer, VADParams, VADState +from pipecat.vad.vad_analyzer import VADAnalyzer, VADState from loguru import logger @@ -105,9 +105,8 @@ class BaseInputTransport(FrameProcessor): await self.stop(frame) elif isinstance(frame, VADParamsUpdateFrame): vad_analyzer = self.vad_analyzer() - if not vad_analyzer: - pass - vad_analyzer.set_params(frame.params) + if vad_analyzer: + vad_analyzer.set_params(frame.params) # Other frames else: await self._internal_push_frame(frame, direction)