Skip to main content

​
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}")