Replace BasePipelineTask with BaseTask

Browse Source

Drops the old abstract `BasePipelineTask` and replaces it with
`BaseTask` — the common base for any runtime task. `BaseTask`
subscribes to a `TaskBus`, participates in the shared
`TaskRegistry`, handles activation / deactivation, end / cancel,
and the full `@job` RPC surface (request_job, job, job_group,
send_job_response / update / stream_*, etc.). It ships a default
`run()` for bus-only tasks; subclasses with their own runtime
(e.g. `PipelineTask`) override it.

...

This commit is contained in:

Aleix Conchillo Flaqué

2026-05-13 19:14:21 -07:00

parent c0b2a8c572

commit 6a738bd3a0

1 changed files with 1279 additions and 58 deletions

Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL

Download Patch File Download Diff File Expand all files Collapse all files

1337

src/pipecat/pipeline/base_task.py

File diff suppressed because it is too large Load Diff