wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

tests: disable RTVI in tests by default

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2026-01-21 14:31:04 -08:00
parent 124a3c35af
commit 0ee11ad333
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/pipecat/tests/utils.py
View File

@@ -123,9 +123,10 @@ class QueuedFrameProcessor(FrameProcessor):
async def run_test( async def run_test(
processor: FrameProcessor, processor: FrameProcessor,
*, *,
frames_to_send: Sequence[Frame], enable_rtvi: bool = False,
expected_down_frames: Optional[Sequence[type]] = None, expected_down_frames: Optional[Sequence[type]] = None,
expected_up_frames: Optional[Sequence[type]] = None, expected_up_frames: Optional[Sequence[type]] = None,
frames_to_send: Sequence[Frame],
ignore_start: bool = True, ignore_start: bool = True,
observers: Optional[List[BaseObserver]] = None, observers: Optional[List[BaseObserver]] = None,
pipeline_params: Optional[PipelineParams] = None, pipeline_params: Optional[PipelineParams] = None,
@@ -139,9 +140,10 @@ async def run_test(
Args: Args:
processor: The frame processor to test. processor: The frame processor to test.
frames_to_send: Sequence of frames to send through the processor. enable_rtvi: Whether RTVI should be enabled in this test.
expected_down_frames: Expected frame types flowing downstream (optional). expected_down_frames: Expected frame types flowing downstream (optional).
expected_up_frames: Expected frame types flowing upstream (optional). expected_up_frames: Expected frame types flowing upstream (optional).
frames_to_send: Sequence of frames to send through the processor.
ignore_start: Whether to ignore StartFrames in frame validation. ignore_start: Whether to ignore StartFrames in frame validation.
observers: Optional list of observers to attach to the pipeline. observers: Optional list of observers to attach to the pipeline.
pipeline_params: Optional pipeline parameters. pipeline_params: Optional pipeline parameters.
@@ -173,9 +175,10 @@ async def run_test(
task = PipelineTask( task = PipelineTask(
pipeline, pipeline,
params=pipeline_params,
observers=observers,
cancel_on_idle_timeout=False, cancel_on_idle_timeout=False,
enable_rtvi=enable_rtvi,
observers=observers,
params=pipeline_params,
) )
async def push_frames(): async def push_frames():