cadrumo.application.operations.persistence._journal_snapshot_validation module¶

Private validators for durable operation journal snapshots and event batches.

validate_request_storage(snapshot)[source]¶

Return type:: None
Parameters:: snapshot (OperationPersistedSnapshot)

validate_secret_state(snapshot)[source]¶

Return type:: None
Parameters:: snapshot (OperationPersistedSnapshot)

validate_executor_entry(snapshot, entered_at)[source]¶

Keep executor entry inside the operation timeline and lifecycle.

Return type:

None

Parameters:

snapshot (OperationPersistedSnapshot)
entered_at (datetime | None)

validate_secret_requirement(snapshot, requirement, entered_at)[source]¶

Keep an ephemeral secret requirement bound to its operation.

Return type:

None

Parameters:

snapshot (OperationPersistedSnapshot)
requirement (OperationSecretRequirement)
entered_at (datetime | None)

validate_deadline_and_cancellation_state(snapshot)[source]¶

Keep durable deadline and cooperative-stop facts ordered and correlated.

Return type:: None
Parameters:: snapshot (OperationPersistedSnapshot)

validate_deferred_cancellation(snapshot, acknowledged_at)[source]¶

Require deferred cancellation to retain an active executor handoff.

Return type:

None

Parameters:

snapshot (OperationPersistedSnapshot)
acknowledged_at (datetime | None)

validate_safety_timestamps(execution_deadline, cleanup_deadline, requested_at, acknowledged_at)[source]¶

Require every optional deadline and cancellation timestamp to be UTC-aware.

Return type:

None

Parameters:

execution_deadline (datetime | None)
cleanup_deadline (datetime | None)
requested_at (datetime | None)
acknowledged_at (datetime | None)

validate_execution_deadline(started_at, execution_deadline)[source]¶

Require an execution deadline to follow operation creation.

Return type:

None

Parameters:

started_at (datetime)
execution_deadline (datetime | None)

validate_unrequested_cancellation(cleanup_deadline, acknowledged_at)[source]¶

Reject cleanup or acknowledgement facts without a cancellation request.

Return type:

None

Parameters:

cleanup_deadline (datetime | None)
acknowledged_at (datetime | None)

validate_requested_cancellation(snapshot, requested_at, cleanup_deadline, acknowledged_at)[source]¶

Keep requested cancellation facts ordered through settlement.

Return type:

None

Parameters:

snapshot (OperationPersistedSnapshot)
requested_at (datetime)
cleanup_deadline (datetime | None)
acknowledged_at (datetime | None)

validate_cancellation_acknowledgement(snapshot, requested_at, acknowledged_at)[source]¶

Require an acknowledgement to follow a cancellation request.

Return type:

None

Parameters:

snapshot (OperationPersistedSnapshot)
requested_at (datetime)
acknowledged_at (datetime | None)

validate_checkpoint_state(snapshot)[source]¶

Return type:: None
Parameters:: snapshot (OperationPersistedSnapshot)

validate_idempotency_claim(snapshot)[source]¶

Return type:: None
Parameters:: snapshot (OperationPersistedSnapshot)

validate_pending_interaction(snapshot)[source]¶

Return type:: None
Parameters:: snapshot (OperationPersistedSnapshot)

validate_consumed_interactions(snapshot)[source]¶

Return type:: None
Parameters:: snapshot (OperationPersistedSnapshot)