qih dZddlZddlmZddlmZddlmZmZddl m Z ddl m Z eGdd Z Gd d e Zy) zBase pipeline task implementation for managing pipeline execution. This module provides the abstract base class and configuration for pipeline tasks that manage the lifecycle and execution of frame processing pipelines. N)abstractmethod) dataclass) AsyncIterableIterable)Frame) BaseObjectc0eZdZUdZej ed<y)PipelineTaskParamszConfiguration parameters for pipeline task execution. Parameters: loop: The asyncio event loop to use for task execution. loopN)__name__ __module__ __qualname____doc__asyncioAbstractEventLoop__annotations__L/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/pipeline/base_task.pyr r s  # ##rr ceZdZdZedefdZedZedZede fdZ ede fd Z ed e e ee zfd Zy ) BasePipelineTaskzAbstract base class for pipeline task implementations. Defines the interface for managing pipeline execution lifecycle, including starting, stopping, and frame queuing operations. returncy)zCheck if the pipeline task has finished execution. Returns: True if all processors have stopped and the task is complete. Nrselfs r has_finishedzBasePipelineTask.has_finished(s rc Kyw)zSchedule the pipeline to stop after processing all queued frames. Implementing classes should send an EndFrame or equivalent signal to gracefully terminate the pipeline once all current processing is complete. Nrrs rstop_when_donezBasePipelineTask.stop_when_done1  c Kyw)zImmediately stop the running pipeline. Implementing classes should cancel all running tasks and stop frame processing without waiting for completion. Nrrs rcancelzBasePipelineTask.cancel:rr paramsc Kyw)aStart and run the pipeline with the given parameters. Implementing classes should initialize and execute the pipeline using the provided configuration parameters. Args: params: Configuration parameters for pipeline execution. Nr)rr#s rrunzBasePipelineTask.runC  r framec Kyw)zQueue a single frame for processing by the pipeline. Implementing classes should add the frame to their processing queue for downstream handling. Args: frame: The frame to be processed. Nr)rr's r queue_framezBasePipelineTask.queue_frameOr&r framesc Kyw)aQueue multiple frames for processing by the pipeline. Implementing classes should process the iterable/async iterable and add all frames to their processing queue. Args: frames: An iterable or async iterable of frames to be processed. Nr)rr*s r queue_frameszBasePipelineTask.queue_frames[r&r N)r r rrrboolrrr"r r%rr)rrr,rrrrr!s  d        2      u      %=;O)O    rr)rrabcr dataclassesrtypingrrpipecat.frames.framesrpipecat.utils.base_objectrr rrrrr3sE !*'0 $$ $D zD r