Exceptions - Pipecat

TaskError

from pipecat_subagents.agents.task_context import TaskError

Raised when a single-agent task (via TaskContext) is cancelled due to a worker error or timeout.

try:
    async with self.task("worker", payload=data, timeout=30) as t:
        async for event in t:
            ...
    print(t.response)
except TaskError as e:
    print(f"Task failed: {e}")

TaskGroupError

from pipecat_subagents.agents.task_context import TaskGroupError

Raised when a task group (via TaskGroupContext) is cancelled due to a worker error or timeout. Also raised if agents are not ready within the specified timeout.

try:
    async with self.task_group("w1", "w2", payload=data, timeout=30) as tg:
        async for event in tg:
            ...
    print(tg.responses)
except TaskGroupError as e:
    print(f"Task group failed: {e}")