Exceptions

Error types for Pipecat job coordination: JobError and the exceptions raised by JobContext-based single-agent jobs.

​

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. When the worker isn’t ready within the timeout, job() raises JobGroupError instead.

try:
    async with self.job("worker", params=JobParams(payload=data, timeout=30)) as j:
        async for event in j:
            ...
    print(j.response)
except (JobError, JobGroupError) 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", params=JobGroupParams(payload=data, timeout=30)) as jg:
        async for event in jg:
            ...
    print(jg.responses)
except JobGroupError as e:
    print(f"Job group failed: {e}")