Exceptions

from pipecat.pipeline.job_context import JobError

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

from pipecat.pipeline.job_context import JobGroupError

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