Skip to main content

Documentation Index

Fetch the complete documentation index at: https://docs.pipecat.ai/llms.txt

Use this file to discover all available pages before exploring further.

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