Coverage for src / lexigram / contracts / infra / tasks / exceptions.py: 0%
5 statements
« prev ^ index » next coverage.py v7.13.5, created at 2026-08-15 18:57 +0800
« prev ^ index » next coverage.py v7.13.5, created at 2026-08-15 18:57 +0800
1"""Task queue error types.
3These are the expected, recoverable failure types that task queue operations
4can return as ``Err`` values inside ``Result[…, TaskQueueError]``.
6Infrastructure failures (broker connection lost, authentication broken)
7must still be raised as exceptions — do not wrap them in ``Result``.
9Error hierarchy
10---------------
11::
13 TaskQueueError Base for all expected task queue failures
14 ├── QueueFullError Queue has reached its capacity limit
15 └── TaskNotFoundError (defined in lexigram-tasks; extends TaskQueueError)
16"""
18from __future__ import annotations
20from lexigram.contracts.exceptions.domain import DomainError
23class TaskQueueError(DomainError):
24 """Base class for expected, recoverable task queue failures.
26 All subtypes indicate situations the caller is expected to handle
27 gracefully (e.g. retry later, notify the user, fall back).
28 """
30 _code: str = "LEX_ERR_TASK_001"
33__all__ = [
34 "TaskQueueError",
35]