Exceptions

Error types for job coordination

JobError

from pipecat.pipeline.job_context import JobError

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

try:
    async with self.job("worker", payload=data, timeout=30) as j:
        async for event in j:
            ...
    print(j.response)
except JobError as e:
    print(f"Job failed: {e}")

JobGroupError

from pipecat.pipeline.job_context import JobGroupError

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

try:
    async with self.job_group("w1", "w2", payload=data, timeout=30) as jg:
        async for event in jg:
            ...
    print(jg.responses)
except JobGroupError as e:
    print(f"Job group failed: {e}")