@@ -123,9 +123,10 @@ async def process_frame(self, frame: Frame, direction: FrameDirection):
123123async def run_test (
124124 processor : FrameProcessor ,
125125 * ,
126- frames_to_send : Sequence [ Frame ] ,
126+ enable_rtvi : bool = False ,
127127 expected_down_frames : Optional [Sequence [type ]] = None ,
128128 expected_up_frames : Optional [Sequence [type ]] = None ,
129+ frames_to_send : Sequence [Frame ],
129130 ignore_start : bool = True ,
130131 observers : Optional [List [BaseObserver ]] = None ,
131132 pipeline_params : Optional [PipelineParams ] = None ,
@@ -139,9 +140,10 @@ async def run_test(
139140
140141 Args:
141142 processor: The frame processor to test.
142- frames_to_send: Sequence of frames to send through the processor .
143+ enable_rtvi: Whether RTVI should be enabled in this test .
143144 expected_down_frames: Expected frame types flowing downstream (optional).
144145 expected_up_frames: Expected frame types flowing upstream (optional).
146+ frames_to_send: Sequence of frames to send through the processor.
145147 ignore_start: Whether to ignore StartFrames in frame validation.
146148 observers: Optional list of observers to attach to the pipeline.
147149 pipeline_params: Optional pipeline parameters.
@@ -173,9 +175,10 @@ async def run_test(
173175
174176 task = PipelineTask (
175177 pipeline ,
176- params = pipeline_params ,
177- observers = observers ,
178178 cancel_on_idle_timeout = False ,
179+ enable_rtvi = enable_rtvi ,
180+ observers = observers ,
181+ params = pipeline_params ,
179182 )
180183
181184 async def push_frames ():
0 commit comments