SyncParallelPipeline

class pipecat.pipeline.sync_parallel_pipeline.SyncFrame[source]

Bases: ControlFrame

This frame is used to know when the internal pipelines have finished.

class pipecat.pipeline.sync_parallel_pipeline.SyncParallelPipelineSource(upstream_queue)[source]

Bases: FrameProcessor

Parameters:

upstream_queue (Queue)

async process_frame(frame, direction)[source]
Parameters:

  • frame (Frame)

  • direction (FrameDirection)

class pipecat.pipeline.sync_parallel_pipeline.SyncParallelPipelineSink(downstream_queue)[source]

Bases: FrameProcessor

Parameters:

downstream_queue (Queue)

async process_frame(frame, direction)[source]
Parameters:

  • frame (Frame)

  • direction (FrameDirection)

class pipecat.pipeline.sync_parallel_pipeline.SyncParallelPipeline(*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)