cayu.tasks.admission

Public Cayu API. Definitions are grouped by their public source module, and definitions from private implementation modules appear on their package’s page; adding a symbol does not move existing links. The import shown at each entry is a supported public namespace. Read the Python API overview and install the required extra.

AdmittedCompletionProposalRequest

from cayu.tasks import AdmittedCompletionProposalRequest

A completion proposal fenced to an exact active execution claim.

Bases: BaseModel.

Fields and attributes

Defaults below are source expressions; Field(...) includes schema/validation settings and default_factory creates a fresh value. Inherited declarations are included. Constructor behavior follows the model or dataclass shown in the bases/decorators.

Name	Type	Default
admission_id	str	required
claim_id	str	required
execution_owner_id	str	required
generation	StrictInt	Field(ge=1, le=WORK_ATTEMPT_ADMISSION_MAX_GENERATIONS)
proposal	CompletionProposalCreate	required

validate_identity (method)

AdmittedCompletionProposalRequest.validate_identity(value: str, info) -> str

copy_proposal (method)

AdmittedCompletionProposalRequest.copy_proposal(value: object) -> object

Release source · Runtime guarantees · Capability guides

WorkAttemptAdmission

from cayu.tasks import WorkAttemptAdmission

Durable, bounded admission intent or active receipt.

Bases: BaseModel.

Fields and attributes

Defaults below are source expressions; Field(...) includes schema/validation settings and default_factory creates a fresh value. Inherited declarations are included. Constructor behavior follows the model or dataclass shown in the bases/decorators.

Name	Type	Default
admission_id	str	required
prepare_request_sha256	str	required
state	WorkAttemptAdmissionState	required
attempt_id	str	required
task_id	str	required
session_id	str	required
interaction_id	str	required
kind	Literal['initial', 'continuation']	required
source_request_sha256	str	required
contract	WorkContractRef	required
session_invocation	SessionInvocationBinding	required
source_execution_profile_fingerprint	str	required
run_semantics	WorkAttemptRunSemantics | None	None
source_request	WorkAttemptSourceRequest | None	None
claim	WorkAttemptExecutionClaim	required
attempt	WorkAttempt | None	None
continuation	WorkAttemptContinuationContext | None	None
session_evidence_sha256	str | None	None
recovery_evidence_sha256	str | None	None
prepared_at	datetime	required
activated_at	datetime | None	None
execution_entry	WorkAttemptExecutionEntry | None	None
execution_stop	WorkAttemptExecutionStop | None	None

copy_source_request (method)

WorkAttemptAdmission.copy_source_request(value: object) -> object

copy_execution_stop (method)

WorkAttemptAdmission.copy_execution_stop(value: object) -> object

copy_execution_entry (method)

WorkAttemptAdmission.copy_execution_entry(value: object) -> object

copy_run_semantics (method)

WorkAttemptAdmission.copy_run_semantics(value: object) -> object

validate_identity (method)

WorkAttemptAdmission.validate_identity(value: str, info) -> str

validate_linked_identity (method)

WorkAttemptAdmission.validate_linked_identity(value: str, info) -> str

validate_digest (method)

WorkAttemptAdmission.validate_digest(value: str | None, info) -> str | None

copy_contract (method)

WorkAttemptAdmission.copy_contract(value: object) -> object

copy_session_invocation (method)

WorkAttemptAdmission.copy_session_invocation(value: object) -> object

copy_claim (method)

WorkAttemptAdmission.copy_claim(value: object) -> object

copy_attempt (method)

WorkAttemptAdmission.copy_attempt(value: object) -> object

copy_continuation (method)

WorkAttemptAdmission.copy_continuation(value: object) -> object

normalize_timestamp (method)

WorkAttemptAdmission.normalize_timestamp(value: datetime | None, info) -> datetime | None

validate_state (method)

WorkAttemptAdmission.validate_state() -> WorkAttemptAdmission

Release source · Runtime guarantees · Capability guides

WorkAttemptAdmissionActivate

from cayu.tasks import WorkAttemptAdmissionActivate

Exact session evidence required to publish one prepared admission.

Bases: BaseModel.

Fields and attributes

Defaults below are source expressions; Field(...) includes schema/validation settings and default_factory creates a fresh value. Inherited declarations are included. Constructor behavior follows the model or dataclass shown in the bases/decorators.

Name	Type	Default
admission_id	str	required
claim_id	str	required
prepare_request_sha256	str	required
session_evidence_sha256	str	required

validate_identity (method)

WorkAttemptAdmissionActivate.validate_identity(value: str, info) -> str

validate_digest (method)

WorkAttemptAdmissionActivate.validate_digest(value: str, info) -> str

Release source · Runtime guarantees · Capability guides

WorkAttemptAdmissionConflict

from cayu.tasks import WorkAttemptAdmissionConflict

A stable admission identity is bound to conflicting authority.

Bases: ValueError.

This type’s implementation and inherited behavior are available in the linked release source.

Release source · Runtime guarantees · Capability guides

WorkAttemptAdmissionPrepare

from cayu.tasks import WorkAttemptAdmissionPrepare

Store request that reserves one exact attempt before session mutation.

Bases: BaseModel.

Fields and attributes

Defaults below are source expressions; Field(...) includes schema/validation settings and default_factory creates a fresh value. Inherited declarations are included. Constructor behavior follows the model or dataclass shown in the bases/decorators.

Name	Type	Default
admission_id	str	required
claim_id	str	required
attempt_id	str	required
task_id	str	required
session_id	str	required
interaction_id	str	required
worker_id	str	required
task_lease_expires_at	datetime | None	None
execution_owner_id	str	required
generation	StrictInt	Field(ge=1, le=WORK_ATTEMPT_ADMISSION_MAX_GENERATIONS)
lease_seconds	StrictInt	Field(ge=1, le=WORK_ATTEMPT_ADMISSION_LEASE_MAX_SECONDS)
kind	Literal['initial', 'continuation']	required
predecessor_admission_id	str | None	None
source_request_sha256	str	required
contract	WorkContractRef	required
session_invocation	SessionInvocationBinding	required
source_execution_profile_fingerprint	str	required
run_semantics	WorkAttemptRunSemantics | None	None
source_request	WorkAttemptSourceRequest | None	None

copy_source_request (method)

WorkAttemptAdmissionPrepare.copy_source_request(value: object) -> object

copy_run_semantics (method)

WorkAttemptAdmissionPrepare.copy_run_semantics(value: object) -> object

validate_identity (method)

WorkAttemptAdmissionPrepare.validate_identity(value: str | None, info) -> str | None

validate_linked_identity (method)

WorkAttemptAdmissionPrepare.validate_linked_identity(value: str, info) -> str

normalize_task_lease_expires_at (method)

WorkAttemptAdmissionPrepare.normalize_task_lease_expires_at(value: datetime | None) -> datetime | None

validate_digest (method)

WorkAttemptAdmissionPrepare.validate_digest(value: str, info) -> str

copy_contract (method)

WorkAttemptAdmissionPrepare.copy_contract(value: object) -> object

copy_session_invocation (method)

WorkAttemptAdmissionPrepare.copy_session_invocation(value: object) -> object

validate_predecessor (method)

WorkAttemptAdmissionPrepare.validate_predecessor() -> WorkAttemptAdmissionPrepare

Release source · Runtime guarantees · Capability guides

WorkAttemptAdmissionState

from cayu.tasks import WorkAttemptAdmissionState

Bases: StrEnum.

Fields and attributes

Defaults below are source expressions; Field(...) includes schema/validation settings and default_factory creates a fresh value. Inherited declarations are included. Constructor behavior follows the model or dataclass shown in the bases/decorators.

Name	Type	Default
PREPARING	class attribute	'preparing'
ACTIVE	class attribute	'active'
RECOVERING	class attribute	'recovering'
RELEASED	class attribute	'released'

Release source · Runtime guarantees · Capability guides

WorkAttemptClaimRenewalRequest

from cayu.tasks import WorkAttemptClaimRenewalRequest

Public request to renew the caller’s current execution generation.

Bases: BaseModel.

Fields and attributes

Defaults below are source expressions; Field(...) includes schema/validation settings and default_factory creates a fresh value. Inherited declarations are included. Constructor behavior follows the model or dataclass shown in the bases/decorators.

Name	Type	Default
admission_id	str	required
claim_id	str	required
worker_id	str	required
generation	StrictInt	Field(ge=1, le=WORK_ATTEMPT_ADMISSION_MAX_GENERATIONS)
lease_seconds	StrictInt	Field(ge=1, le=WORK_ATTEMPT_ADMISSION_LEASE_MAX_SECONDS)

validate_identity (method)

WorkAttemptClaimRenewalRequest.validate_identity(value: str, info) -> str

Release source · Runtime guarantees · Capability guides

WorkAttemptContinuationContext

from cayu.tasks import WorkAttemptContinuationContext

Exact bounded rejection evidence supplied to the next attempt.

Bases: BaseModel.

Fields and attributes

Defaults below are source expressions; Field(...) includes schema/validation settings and default_factory creates a fresh value. Inherited declarations are included. Constructor behavior follows the model or dataclass shown in the bases/decorators.

Name	Type	Default
prior_admission_id	str	required
prior_attempt_id	str	required
proposal_id	str	required
decision	CompletionDecision	required
application_idempotency_key	str	required
gap_fingerprint	str	required

validate_identity (method)

WorkAttemptContinuationContext.validate_identity(value: str, info) -> str

validate_gap_fingerprint (method)

WorkAttemptContinuationContext.validate_gap_fingerprint(value: str) -> str

copy_decision (method)

WorkAttemptContinuationContext.copy_decision(value: object) -> object

validate_decision_gaps (method)

WorkAttemptContinuationContext.validate_decision_gaps() -> WorkAttemptContinuationContext

gaps (property)

WorkAttemptContinuationContext.gaps() -> tuple[CompletionGap, ...]

Return the decision-owned typed gaps without persisting a duplicate.

Release source · Runtime guarantees · Capability guides

WorkAttemptExecutionClaim

from cayu.tasks import WorkAttemptExecutionClaim

One immutable generation of renewable work-attempt execution authority.

Bases: BaseModel.

Fields and attributes

Defaults below are source expressions; Field(...) includes schema/validation settings and default_factory creates a fresh value. Inherited declarations are included. Constructor behavior follows the model or dataclass shown in the bases/decorators.

Name	Type	Default
admission_id	str	required
claim_id	str	required
worker_id	str	required
execution_owner_id	str	required
generation	StrictInt	Field(ge=1, le=WORK_ATTEMPT_ADMISSION_MAX_GENERATIONS)
request_sha256	str	required
claimed_at	datetime	required
lease_expires_at	datetime	required
renewal	WorkAttemptExecutionClaimRenewal | None	None

copy_renewal (method)

WorkAttemptExecutionClaim.copy_renewal(value: object) -> object

validate_identity (method)

WorkAttemptExecutionClaim.validate_identity(value: str, info) -> str

validate_request_sha256 (method)

WorkAttemptExecutionClaim.validate_request_sha256(value: str) -> str

normalize_timestamp (method)

WorkAttemptExecutionClaim.normalize_timestamp(value: datetime, info) -> datetime

validate_lease_window (method)

WorkAttemptExecutionClaim.validate_lease_window() -> WorkAttemptExecutionClaim

Release source · Runtime guarantees · Capability guides

WorkAttemptExecutionClaimLost

from cayu.tasks import WorkAttemptExecutionClaimLost

The caller no longer owns the exact active work-attempt generation.

Bases: ValueError.

This type’s implementation and inherited behavior are available in the linked release source.

Release source · Runtime guarantees · Capability guides

WorkAttemptExecutionClaimRenewal

from cayu import WorkAttemptExecutionClaimRenewal

Store-clock evidence for the enclosing claim’s latest lease extension.

Bases: BaseModel.

Fields and attributes

Defaults below are source expressions; Field(...) includes schema/validation settings and default_factory creates a fresh value. Inherited declarations are included. Constructor behavior follows the model or dataclass shown in the bases/decorators.

Name	Type	Default
renewed_at	datetime	required
lease_seconds	StrictInt	Field(ge=1, le=WORK_ATTEMPT_ADMISSION_LEASE_MAX_SECONDS)

normalize_timestamp (method)

WorkAttemptExecutionClaimRenewal.normalize_timestamp(value: datetime) -> datetime

Release source · Runtime guarantees · Capability guides

WorkAttemptExecutionClaimRequest

from cayu.tasks import WorkAttemptExecutionClaimRequest

Renew or replace one attempt’s process-aware execution generation.

Bases: BaseModel.

Fields and attributes

Defaults below are source expressions; Field(...) includes schema/validation settings and default_factory creates a fresh value. Inherited declarations are included. Constructor behavior follows the model or dataclass shown in the bases/decorators.

Name	Type	Default
admission_id	str	required
claim_id	str	required
worker_id	str	required
execution_owner_id	str	required
generation	StrictInt	Field(ge=1, le=WORK_ATTEMPT_ADMISSION_MAX_GENERATIONS)
lease_seconds	StrictInt	Field(ge=1, le=WORK_ATTEMPT_ADMISSION_LEASE_MAX_SECONDS)

validate_identity (method)

WorkAttemptExecutionClaimRequest.validate_identity(value: str, info) -> str

Release source · Runtime guarantees · Capability guides

WorkAttemptExecutionRequest

from cayu.tasks import WorkAttemptExecutionRequest

Public, stable identities for one runtime-owned execution entrance.

Bases: BaseModel.

Fields and attributes

Defaults below are source expressions; Field(...) includes schema/validation settings and default_factory creates a fresh value. Inherited declarations are included. Constructor behavior follows the model or dataclass shown in the bases/decorators.

Name	Type	Default
admission_id	str	required
claim_id	str	required
attempt_id	str	required
interaction_id	str	required
worker_id	str	required
task_id	str | None	None
task_lease_expires_at	datetime | None	None
predecessor_admission_id	str | None	None
generation	StrictInt	Field(ge=1, le=WORK_ATTEMPT_ADMISSION_MAX_GENERATIONS)
lease_seconds	StrictInt	Field(ge=1, le=WORK_ATTEMPT_ADMISSION_LEASE_MAX_SECONDS)

validate_identity (method)

WorkAttemptExecutionRequest.validate_identity(value: str | None, info) -> str | None

validate_task_id (method)

WorkAttemptExecutionRequest.validate_task_id(value: str | None) -> str | None

normalize_task_lease_expires_at (method)

WorkAttemptExecutionRequest.normalize_task_lease_expires_at(value: datetime | None) -> datetime | None

Release source · Runtime guarantees · Capability guides

WorkAttemptProposalRequest

from cayu.tasks import WorkAttemptProposalRequest

Public proposal request completed with process authority by CayuApp.

Bases: BaseModel.

Fields and attributes

Defaults below are source expressions; Field(...) includes schema/validation settings and default_factory creates a fresh value. Inherited declarations are included. Constructor behavior follows the model or dataclass shown in the bases/decorators.

Name	Type	Default
admission_id	str	required
claim_id	str	required
generation	StrictInt	Field(ge=1, le=WORK_ATTEMPT_ADMISSION_MAX_GENERATIONS)
proposal	CompletionProposalCreate	required

validate_identity (method)

WorkAttemptProposalRequest.validate_identity(value: str, info) -> str

copy_proposal (method)

WorkAttemptProposalRequest.copy_proposal(value: object) -> object

Release source · Runtime guarantees · Capability guides

WorkAttemptRecoveryActivate

from cayu.tasks import WorkAttemptRecoveryActivate

Positive session-settlement evidence that activates a recovery generation.

Bases: BaseModel.

Fields and attributes

Defaults below are source expressions; Field(...) includes schema/validation settings and default_factory creates a fresh value. Inherited declarations are included. Constructor behavior follows the model or dataclass shown in the bases/decorators.

Name	Type	Default
admission_id	str	required
claim_id	str	required
generation	StrictInt	Field(ge=2, le=WORK_ATTEMPT_ADMISSION_MAX_GENERATIONS)
recovery_evidence_sha256	str	required

validate_identity (method)

WorkAttemptRecoveryActivate.validate_identity(value: str, info) -> str

validate_recovery_evidence_sha256 (method)

WorkAttemptRecoveryActivate.validate_recovery_evidence_sha256(value: str) -> str

Release source · Runtime guarantees · Capability guides

WorkAttemptRecoveryRequest

from cayu.tasks import WorkAttemptRecoveryRequest

Public request to replace one expired execution generation.

Bases: BaseModel.

Fields and attributes

Defaults below are source expressions; Field(...) includes schema/validation settings and default_factory creates a fresh value. Inherited declarations are included. Constructor behavior follows the model or dataclass shown in the bases/decorators.

Name	Type	Default
admission_id	str	required
claim_id	str	required
worker_id	str	required
generation	StrictInt	Field(ge=2, le=WORK_ATTEMPT_ADMISSION_MAX_GENERATIONS)
lease_seconds	StrictInt	Field(ge=1, le=WORK_ATTEMPT_ADMISSION_LEASE_MAX_SECONDS)

validate_identity (method)

WorkAttemptRecoveryRequest.validate_identity(value: str, info) -> str

Release source · Runtime guarantees · Capability guides

WorkAttemptRecoveryRequired

from cayu.tasks import WorkAttemptRecoveryRequired

Durable admission remains fenced pending exact session reconciliation.

Bases: RuntimeError.

This type’s implementation and inherited behavior are available in the linked release source.

Release source · Runtime guarantees · Capability guides