ParallelPipeline
- class pipecat.pipeline.parallel_pipeline.ParallelPipelineSource(upstream_queue, push_frame_func)[source]
Bases:
FrameProcessor- Parameters:
upstream_queue (Queue)
push_frame_func (Callable[[Frame, FrameDirection], Awaitable[None]])
- async process_frame(frame, direction)[source]
- Parameters:
frame (Frame)
direction (FrameDirection)
- class pipecat.pipeline.parallel_pipeline.ParallelPipelineSink(downstream_queue, push_frame_func)[source]
Bases:
FrameProcessor- Parameters:
downstream_queue (Queue)
push_frame_func (Callable[[Frame, FrameDirection], Awaitable[None]])
- async process_frame(frame, direction)[source]
- Parameters:
frame (Frame)
direction (FrameDirection)
- class pipecat.pipeline.parallel_pipeline.ParallelPipeline(*args)[source]
Bases:
BasePipeline- processors_with_metrics()[source]
- Return type:
List[FrameProcessor]
- async setup(setup)[source]
- Parameters:
setup (FrameProcessorSetup)
- async cleanup()[source]
- async process_frame(frame, direction)[source]
- Parameters:
frame (Frame)
direction (FrameDirection)