cayu.tasks.InterruptedTaskContinuationClaimPage
Part of cayu.tasks.base. Read the Python API overview and install the required extra.
from cayu.tasks import InterruptedTaskContinuationClaimPageOne bounded continuation scan and its optional atomic task claim.
Bases: BaseModel.
Fields and attributes
Section titled “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 |
|---|---|---|
task |
Task | None |
None |
next_after |
tuple[datetime, str] | None |
None |
scanned_candidates |
StrictInt |
Field(ge=0, le=_TASK_INTERRUPTED_HANDOFF_RECOVERY_MAX_PAGE_SIZE) |
rejected_candidates |
StrictInt |
Field(ge=0, le=_TASK_INTERRUPTED_HANDOFF_RECOVERY_MAX_PAGE_SIZE) |
filtered_candidates |
StrictInt |
Field(default=0, ge=0, le=_TASK_INTERRUPTED_HANDOFF_RECOVERY_MAX_PAGE_SIZE) |
replayed |
StrictBool |
False |
exhausted |
StrictBool |
required |
copy_claimed_task (method)
Section titled “copy_claimed_task (method)”InterruptedTaskContinuationClaimPage.copy_claimed_task(value: Task | None) -> Task | Nonevalidate_next_after (method)
Section titled “validate_next_after (method)”InterruptedTaskContinuationClaimPage.validate_next_after(value: tuple[datetime, str] | None) -> tuple[datetime, str] | Nonevalidate_page (method)
Section titled “validate_page (method)”InterruptedTaskContinuationClaimPage.validate_page() -> InterruptedTaskContinuationClaimPage