solutions_backend.orders.manager

Durable command router for canonical WorkOrder operations.

Classes

`GovernedProofStore`

Bases: Protocol

`admit`

admit(proof: GovernedActionProof) -> GovernedActionProof

`WorkOrderEffects`

Bases: Protocol

Execute or verification-only recover one exact external command.

`execute`

execute(work_order, command, intent, operation_id)

`recover`

recover(work_order, command, intent, operation_id)

`WorkOrderOperationError`

Bases: RuntimeError

A durable command conflicted or failed before a safe terminal result.

`WorkOrderOperationManager`

Claim once, build through Core, prove external outcomes, and persist canonically.

`execute`

execute(request: WorkOrderOperationRequest) -> WorkOrderOperationResult

Execute or replay one exact command without ever blindly retrying an effect.

`get`

get(operation_id) -> WorkOrderOperationResult | None

Return a terminal safe result, or None while running/unknown.

`get_state`

get_state(operation_id: UUID) -> WorkOrderOperationState

Return the exact durable claim state for polling and recovery visibility.

`get_work_order`

get_work_order(work_order_id: WorkOrderId) -> WorkOrder

Return the exact canonical aggregate snapshot.

`list_calendar`

list_calendar(**window)

Return canonical appointments overlapping one explicit window.

`list_timeline`

list_timeline(work_order_id, **page)

Return immutable business history for one canonical order.

`list_work_orders`

list_work_orders(**filters)

Return one stable keyset page for operational queues.

`WorkOrderOperationStore`

Bases: Protocol

`claim`

claim(operation_id: UUID, work_order_id: WorkOrderId, kind: str, input_digest: str, request: dict[str, object], expected_version: int, now: datetime, lease_expires_at: datetime) -> WorkOrderOperationClaim

`complete`

complete(operation_id: UUID, status: WorkOrderOperationStatus, result: dict[str, object], safe_code: str | None, completed_at: datetime) -> WorkOrderOperationState

`get`

get(operation_id: UUID) -> WorkOrderOperationState

`mark_unknown`

mark_unknown(operation_id: UUID, safe_code: str) -> WorkOrderOperationState

`WorkOrderStore`

Bases: Protocol

`apply`

apply(before: WorkOrder, after: WorkOrder, history: HistoryEntry) -> WorkOrder

`find_command`

find_command(command_id: UUID) -> tuple[HistoryEntry, WorkOrder] | None

`get`

get(work_order_id: WorkOrderId) -> WorkOrder

`list_calendar`

list_calendar(window_start: datetime, window_end: datetime, limit: int = 500) -> tuple[tuple[tuple[WorkOrder, Appointment], ...], bool]

`list_history`

list_history(work_order_id: WorkOrderId, before_version: int | None = None, limit: int = 100) -> tuple[tuple[HistoryEntry, ...], bool]

`list_page`

list_page(phase: str | None = None, client_id: ClientId | None = None, property_id: PropertyId | None = None, before_updated_at: datetime | None = None, before_id: UUID | None = None, limit: int = 50) -> tuple[tuple[WorkOrder, ...], bool]