pipeline

Submodules

• base_pipeline
  • BasePipeline
    • BasePipeline.__init__()
• job_context
  • JobStatus
    • JobStatus.COMPLETED
    • JobStatus.CANCELLED
    • JobStatus.FAILED
    • JobStatus.ERROR
    • JobStatus.COMPLETED
    • JobStatus.CANCELLED
    • JobStatus.FAILED
    • JobStatus.ERROR
  • JobError
  • JobGroupError
  • JobGroupResponse
    • JobGroupResponse.job_id
    • JobGroupResponse.responses
  • JobEvent
    • JobEvent.UPDATE
    • JobEvent.STREAM_START
    • JobEvent.STREAM_DATA
    • JobEvent.STREAM_END
    • JobEvent.type
    • JobEvent.data
  • JobGroupEvent
    • JobGroupEvent.UPDATE
    • JobGroupEvent.STREAM_START
    • JobGroupEvent.STREAM_DATA
    • JobGroupEvent.STREAM_END
    • JobGroupEvent.type
    • JobGroupEvent.worker_name
    • JobGroupEvent.data
  • JobGroup
    • JobGroup.job_id
    • JobGroup.worker_names
    • JobGroup.responses
    • JobGroup.timeout_task
    • JobGroup.cancel_on_error
    • JobGroup.event_queue
    • JobGroup.is_done
    • JobGroup.wait()
    • JobGroup.complete()
    • JobGroup.fail()
  • JobGroupContext
    • JobGroupContext.__init__()
    • JobGroupContext.job_id
    • JobGroupContext.responses
  • JobContext
    • JobContext.__init__()
    • JobContext.job_id
    • JobContext.response
• job_decorator
  • job()
• llm_switcher
  • LLMSwitcher
    • LLMSwitcher.__init__()
    • LLMSwitcher.process_frame()
    • LLMSwitcher.llms
    • LLMSwitcher.active_llm
    • LLMSwitcher.run_inference()
    • LLMSwitcher.register_function()
    • LLMSwitcher.register_direct_function()
• parallel_pipeline
  • ParallelPipeline
    • ParallelPipeline.__init__()
    • ParallelPipeline.processors
    • ParallelPipeline.entry_processors
    • ParallelPipeline.processors_with_metrics()
    • ParallelPipeline.setup()
    • ParallelPipeline.cleanup()
    • ParallelPipeline.process_frame()
• pipeline
  • PipelineSource
    • PipelineSource.__init__()
    • PipelineSource.process_frame()
  • PipelineSink
    • PipelineSink.__init__()
    • PipelineSink.process_frame()
  • Pipeline
    • Pipeline.__init__()
    • Pipeline.processors
    • Pipeline.entry_processors
    • Pipeline.processors_with_metrics()
    • Pipeline.setup()
    • Pipeline.cleanup()
    • Pipeline.process_frame()
• runner
  • PipelineRunner
  • WorkerRunner
    • WorkerRunner.__init__()
    • WorkerRunner.bus
    • WorkerRunner.registry
    • WorkerRunner.add_workers()
    • WorkerRunner.run()
    • WorkerRunner.stop_when_done()
    • WorkerRunner.end()
    • WorkerRunner.cancel()
    • WorkerRunner.on_bus_message()
• service_switcher
  • ServiceSwitcherStrategy
    • ServiceSwitcherStrategy.__init__()
    • ServiceSwitcherStrategy.services
    • ServiceSwitcherStrategy.active_service
    • ServiceSwitcherStrategy.handle_frame()
    • ServiceSwitcherStrategy.handle_error()
  • ServiceSwitcherStrategyManual
    • ServiceSwitcherStrategyManual.handle_frame()
  • ServiceSwitcherStrategyFailover
    • ServiceSwitcherStrategyFailover.handle_error()
  • ServiceSwitcher
    • ServiceSwitcher.__init__()
    • ServiceSwitcher.strategy
    • ServiceSwitcher.services
    • ServiceSwitcher.push_frame()
    • ServiceSwitcher.process_frame()
• sync_parallel_pipeline
  • FrameOrder
    • FrameOrder.ARRIVAL
    • FrameOrder.PIPELINE
  • SyncFrame
  • SyncParallelPipelineSource
    • SyncParallelPipelineSource.__init__()
    • SyncParallelPipelineSource.process_frame()
  • SyncParallelPipelineSink
    • SyncParallelPipelineSink.__init__()
    • SyncParallelPipelineSink.process_frame()
  • SyncParallelPipeline
    • SyncParallelPipeline.__init__()
    • SyncParallelPipeline.processors
    • SyncParallelPipeline.entry_processors
    • SyncParallelPipeline.processors_with_metrics()
    • SyncParallelPipeline.setup()
    • SyncParallelPipeline.cleanup()
    • SyncParallelPipeline.process_frame()
• task
  • IdleFrameObserver
    • IdleFrameObserver.__init__()
    • IdleFrameObserver.on_push_frame()
  • PipelineParams
    • PipelineParams.audio_in_sample_rate
    • PipelineParams.audio_out_sample_rate
    • PipelineParams.enable_heartbeats
    • PipelineParams.enable_metrics
    • PipelineParams.enable_usage_metrics
    • PipelineParams.heartbeats_period_secs
    • PipelineParams.heartbeats_monitor_secs
    • PipelineParams.report_only_initial_ttfb
    • PipelineParams.send_initial_empty_metrics
    • PipelineParams.start_metadata
  • PipelineTask
  • PipelineTaskParams
  • PipelineWorker
    • PipelineWorker.__init__()
    • PipelineWorker.params
    • PipelineWorker.bridged
    • PipelineWorker.app_resources
    • PipelineWorker.pipeline
    • PipelineWorker.turn_tracking_observer
    • PipelineWorker.turn_trace_observer
    • PipelineWorker.rtvi
    • PipelineWorker.reached_upstream_types
    • PipelineWorker.reached_downstream_types
    • PipelineWorker.add_observer()
    • PipelineWorker.remove_observer()
    • PipelineWorker.set_reached_upstream_filter()
    • PipelineWorker.set_reached_downstream_filter()
    • PipelineWorker.add_reached_upstream_filter()
    • PipelineWorker.add_reached_downstream_filter()
    • PipelineWorker.has_finished()
    • PipelineWorker.stop_when_done()
    • PipelineWorker.cancel()
    • PipelineWorker.run()
    • PipelineWorker.queue_frame()
    • PipelineWorker.queue_frames()
    • PipelineWorker.flush_pipeline()
    • PipelineWorker.on_bus_message()
• worker
  • IdleFrameObserver
    • IdleFrameObserver.__init__()
    • IdleFrameObserver.on_push_frame()
  • PipelineParams
    • PipelineParams.audio_in_sample_rate
    • PipelineParams.audio_out_sample_rate
    • PipelineParams.enable_heartbeats
    • PipelineParams.enable_metrics
    • PipelineParams.enable_usage_metrics
    • PipelineParams.heartbeats_period_secs
    • PipelineParams.heartbeats_monitor_secs
    • PipelineParams.report_only_initial_ttfb
    • PipelineParams.send_initial_empty_metrics
    • PipelineParams.start_metadata
  • PipelineWorker
    • PipelineWorker.__init__()
    • PipelineWorker.params
    • PipelineWorker.bridged
    • PipelineWorker.app_resources
    • PipelineWorker.pipeline
    • PipelineWorker.turn_tracking_observer
    • PipelineWorker.turn_trace_observer
    • PipelineWorker.rtvi
    • PipelineWorker.reached_upstream_types
    • PipelineWorker.reached_downstream_types
    • PipelineWorker.add_observer()
    • PipelineWorker.remove_observer()
    • PipelineWorker.set_reached_upstream_filter()
    • PipelineWorker.set_reached_downstream_filter()
    • PipelineWorker.add_reached_upstream_filter()
    • PipelineWorker.add_reached_downstream_filter()
    • PipelineWorker.has_finished()
    • PipelineWorker.stop_when_done()
    • PipelineWorker.cancel()
    • PipelineWorker.run()
    • PipelineWorker.queue_frame()
    • PipelineWorker.queue_frames()
    • PipelineWorker.flush_pipeline()
    • PipelineWorker.on_bus_message()
  • PipelineTask
  • PipelineTaskParams
• worker_observer
  • Proxy
    • Proxy.queue
    • Proxy.task
    • Proxy.observer
  • WorkerObserver
    • WorkerObserver.__init__()
    • WorkerObserver.add_observer()
    • WorkerObserver.remove_observer()
    • WorkerObserver.start()
    • WorkerObserver.stop()
    • WorkerObserver.cleanup()
    • WorkerObserver.on_pipeline_started()
    • WorkerObserver.on_process_frame()
    • WorkerObserver.on_push_frame()
• worker_ready_decorator
  • worker_ready()