cadrumo.application.operations.models module¶

Immutable identity, request, snapshot, revision, and receipt contracts.

class OperationReconciliationOutcome(*values)[source]¶

Bases: StrEnum

Closed durable classifications emitted only by the supervisor at restart.

RECOVERED¶

RESUMED¶

INTERRUPTED¶

ORPHANED¶

class OperationIdentity(**data)[source]¶

Bases: BaseModel

Immutable invocation identity, distinct from recovery-action identity.

Parameters:: data (Any)

operation_id: OperationId¶

definition_id: OperationDefinitionId¶

subject_ref: OperationReference¶

class CredentialFreeOperationRequest(**data)[source]¶

Bases: BaseModel

Explicit opt-in base for request payloads safe to retain without credentials.

Parameters:: data (Any)

class OperationRequest(**data)[source]¶

Bases: BaseModel, Generic

Validated typed operand submitted to one registered operation definition.

Parameters:

definition_id (OperationDefinitionId)
subject_ref (OperationReference)
payload (RequestPayloadT)
idempotency_key (Annotated[str, FieldInfo(annotation=NoneType, required=True, metadata=[MinLen(min_length=1), MaxLen(max_length=256)])] | None)

definition_id: OperationDefinitionId¶

subject_ref: OperationReference¶

payload: RequestPayloadT¶

idempotency_key: Annotated[str, Field(min_length=1, max_length=256)] | None¶

class OperationTerminalReceipt(**data)[source]¶

Bases: BaseModel

Settled terminal fact that cannot precede resource cleanup.

Parameters:: data (Any)

identity: OperationIdentity¶

revision: OperationRevision¶

condition: OperationTerminalCondition¶

effect: OperationEffect¶

settled_at: datetime¶

result_ref: OperationReference | None¶

refusal_ref: OperationReference | None¶

failure_error_code: OperationFailureErrorCode | None¶

diagnostic_ref: OperationDiagnosticReference | None¶

validate_terminal_reference_meaning(*, condition, result_ref, refusal_ref, failure_error_code=None)[source]¶

Enforce the canonical terminal result/refusal relationship.

Return type:

None

Parameters:

condition (OperationTerminalCondition)
result_ref (OperationReference | None)
refusal_ref (OperationReference | None)
failure_error_code (str | None)

class OperationSnapshot(**data)[source]¶

Bases: BaseModel, Generic

One immutable, revisioned observation of authoritative operation state.

Parameters:: data (Any)

identity: OperationIdentity¶

request: OperationRequest[RequestPayloadT]¶

revision: OperationRevision¶

lifecycle: OperationLifecycle¶

terminal_condition: OperationTerminalCondition | None¶

effect: OperationEffect¶

phase_code: Annotated[str, Field(min_length=1, max_length=128)] | None¶

updated_at: datetime¶

event_cursor: Annotated[int, Field(ge=0)]¶

terminal_receipt: OperationTerminalReceipt | None¶

new_operation_id()[source]¶

Mint a cryptographically random operation invocation identity.

Return type:: str