Skip to content

cayu.knowledge.changes

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.

from cayu.storage import KnowledgeChange

Metadata-only canonical knowledge mutation published in commit order.

Bases: BaseModel.

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
id str required
sequence int required
kind KnowledgeChangeKind required
entry_id str required
entry_revision int required
committed_at datetime required
operation_id str | None None
relation_id str | None None
KnowledgeChange.validate_identity(value: str | None, info) -> str | None
KnowledgeChange.validate_relation_id(value: str | None) -> str | None
KnowledgeChange.validate_entry_id(value: str) -> str
KnowledgeChange.validate_sequence(value: int) -> int
KnowledgeChange.validate_entry_revision(value: int) -> int
KnowledgeChange.validate_committed_at(value: datetime) -> datetime
KnowledgeChange.validate_relation_change() -> KnowledgeChange

Release source · Runtime guarantees · Capability guides

from cayu.storage import KnowledgeChangeBatch

One bounded ordered change page and its captured accessible high-water mark.

Bases: BaseModel.

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
changes list[KnowledgeChange] Field(default_factory=list)
after_sequence int 0
next_after_sequence int 0
high_water_sequence int 0
truncated bool False
limit int required
KnowledgeChangeBatch.copy_changes(value) -> list[KnowledgeChange]
KnowledgeChangeBatch.validate_sequences(value: int, info) -> int
KnowledgeChangeBatch.validate_limit(value: int) -> int
KnowledgeChangeBatch.validate_truncated(value) -> bool
KnowledgeChangeBatch.validate_page() -> KnowledgeChangeBatch

Release source · Runtime guarantees · Capability guides

from cayu.storage import KnowledgeChangeClaim

One fenced at-least-once lease over an ordered knowledge change.

Bases: BaseModel.

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
consumer_id str required
worker_id str required
claim_id str required
change KnowledgeChange required
attempt int required
claimed_at datetime required
lease_expires_at datetime required
KnowledgeChangeClaim.validate_identity(value: str, info) -> str
KnowledgeChangeClaim.copy_change(value: KnowledgeChange) -> KnowledgeChange
KnowledgeChangeClaim.validate_attempt(value: int) -> int
KnowledgeChangeClaim.validate_datetime(value: datetime, info) -> datetime
KnowledgeChangeClaim.validate_lease_window() -> KnowledgeChangeClaim

Release source · Runtime guarantees · Capability guides

from cayu.storage import KnowledgeChangeConsumerConflict

A knowledge-change consumer or lease fence conflicts with durable state.

Bases: RuntimeError.

KnowledgeChangeConsumerConflict.__init__(reason: str) -> None

Release source · Runtime guarantees · Capability guides

from cayu.storage import KnowledgeChangeConsumerState

Durable cursor and active lease state for one scope-bound consumer.

Bases: BaseModel.

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
consumer_id str required
access_scope_sha256 str required
cursor_sequence int 0
pending_change_sequence int | None None
pending_claim_id str | None None
pending_worker_id str | None None
pending_attempt int 0
claimed_at datetime | None None
lease_expires_at datetime | None None
last_acknowledged_claim_id str | None None
updated_at datetime required
KnowledgeChangeConsumerState.validate_identity(value: str | None, info) -> str | None
KnowledgeChangeConsumerState.validate_scope_digest(value: str) -> str
KnowledgeChangeConsumerState.validate_cursor(value: int) -> int
KnowledgeChangeConsumerState.validate_pending_sequence(value: int | None) -> int | None
KnowledgeChangeConsumerState.validate_pending_attempt(value: int) -> int
KnowledgeChangeConsumerState.validate_datetime(value: datetime | None, info) -> datetime | None
KnowledgeChangeConsumerState.validate_pending_lease() -> KnowledgeChangeConsumerState

Release source · Runtime guarantees · Capability guides

from cayu.storage import KnowledgeChangeKind

Bases: StrEnum.

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
CREATED class attribute 'created'
REVISION_APPENDED class attribute 'revision_appended'
STATUS_TRANSITIONED class attribute 'status_transitioned'
TOMBSTONED class attribute 'tombstoned'
HARD_DELETED class attribute 'hard_deleted'
EXPIRED class attribute 'expired'
RELATION_PUBLISHED class attribute 'relation_published'

Release source · Runtime guarantees · Capability guides

from cayu.storage import MAX_KNOWLEDGE_CHANGE_LIMIT
MAX_KNOWLEDGE_CHANGE_LIMIT = 1000

Release source · Runtime guarantees · Capability guides

from cayu.storage import MAX_KNOWLEDGE_CHANGE_SEQUENCE
MAX_KNOWLEDGE_CHANGE_SEQUENCE = 2 ** 63 - 1

Release source · Runtime guarantees · Capability guides