pipeline
Submodules
- base_pipeline
- base_task
- llm_switcher
- parallel_pipeline
- pipeline
- runner
- service_switcher
- sync_parallel_pipeline
- task
IdleFrameObserverPipelineParamsPipelineParams.audio_in_sample_ratePipelineParams.audio_out_sample_ratePipelineParams.enable_heartbeatsPipelineParams.enable_metricsPipelineParams.enable_usage_metricsPipelineParams.heartbeats_period_secsPipelineParams.heartbeats_monitor_secsPipelineParams.report_only_initial_ttfbPipelineParams.send_initial_empty_metricsPipelineParams.start_metadata
PipelineTaskPipelineTask.__init__()PipelineTask.paramsPipelineTask.app_resourcesPipelineTask.pipelinePipelineTask.turn_tracking_observerPipelineTask.turn_trace_observerPipelineTask.rtviPipelineTask.reached_upstream_typesPipelineTask.reached_downstream_typesPipelineTask.add_observer()PipelineTask.remove_observer()PipelineTask.set_reached_upstream_filter()PipelineTask.set_reached_downstream_filter()PipelineTask.add_reached_upstream_filter()PipelineTask.add_reached_downstream_filter()PipelineTask.has_finished()PipelineTask.stop_when_done()PipelineTask.cancel()PipelineTask.run()PipelineTask.queue_frame()PipelineTask.queue_frames()
- task_observer