Pipeline
- class pipecat.pipeline.pipeline.PipelineSource(upstream_push_frame)[source]
Bases:
FrameProcessor- Parameters:
upstream_push_frame (Callable[[Frame, FrameDirection], Coroutine])
- async process_frame(frame, direction)[source]
- Parameters:
frame (Frame)
direction (FrameDirection)
- class pipecat.pipeline.pipeline.PipelineSink(downstream_push_frame)[source]
Bases:
FrameProcessor- Parameters:
downstream_push_frame (Callable[[Frame, FrameDirection], Coroutine])
- async process_frame(frame, direction)[source]
- Parameters:
frame (Frame)
direction (FrameDirection)
- class pipecat.pipeline.pipeline.Pipeline(processors)[source]
Bases:
BasePipeline- Parameters:
processors (List[FrameProcessor])
- processors_with_metrics()[source]
- async setup(setup)[source]
- Parameters:
setup (FrameProcessorSetup)
- async cleanup()[source]
- async process_frame(frame, direction)[source]
- Parameters:
frame (Frame)
direction (FrameDirection)