cayu.storage.work_context_sqlite
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.
SQLiteAgentWorkContextStore
Section titled “SQLiteAgentWorkContextStore”from cayu.storage import SQLiteAgentWorkContextStoreSQLite implementation with transaction-fenced current pointers.
Bases: AgentWorkContextStore.
publish_work_context (method)
Section titled “publish_work_context (method)”async SQLiteAgentWorkContextStore.publish_work_context(context: AgentWorkContext, *, expected_revision: int | None) -> AgentWorkContextPublicationReceiptload_work_context (method)
Section titled “load_work_context (method)”async SQLiteAgentWorkContextStore.load_work_context(task_id: str, *, revision: int | None=None) -> AgentWorkContext | Noneload_work_context_publication (method)
Section titled “load_work_context_publication (method)”async SQLiteAgentWorkContextStore.load_work_context_publication(operation_id: str) -> AgentWorkContextPublicationReceipt | Noneadvance_recall_checkpoint (method)
Section titled “advance_recall_checkpoint (method)”async SQLiteAgentWorkContextStore.advance_recall_checkpoint(checkpoint: AgentRecallCheckpoint, *, expected_revision: int | None) -> AgentRecallCheckpointload_recall_checkpoint (method)
Section titled “load_recall_checkpoint (method)”async SQLiteAgentWorkContextStore.load_recall_checkpoint(key: AgentRecallCheckpointKey, *, revision: int | None=None) -> AgentRecallCheckpoint | Nonestage_recall_delivery (method)
Section titled “stage_recall_delivery (method)”async SQLiteAgentWorkContextStore.stage_recall_delivery(delivery: AgentRecallDelivery) -> AgentRecallDeliveryRecordload_recall_delivery (method)
Section titled “load_recall_delivery (method)”async SQLiteAgentWorkContextStore.load_recall_delivery(delivery_id: str) -> AgentRecallDeliveryRecord | Noneclaim_recall_delivery (method)
Section titled “claim_recall_delivery (method)”async SQLiteAgentWorkContextStore.claim_recall_delivery(key: AgentRecallCheckpointKey, *, claim_id: str, worker_id: str, lease_seconds: float) -> AgentRecallDeliveryRecord | Nonerenew_recall_delivery (method)
Section titled “renew_recall_delivery (method)”async SQLiteAgentWorkContextStore.renew_recall_delivery(claim: AgentRecallDeliveryClaim, *, lease_seconds: float) -> AgentRecallDeliveryRecordrelease_recall_delivery (method)
Section titled “release_recall_delivery (method)”async SQLiteAgentWorkContextStore.release_recall_delivery(claim: AgentRecallDeliveryClaim, *, release_id: str, reason: str, released_at: datetime) -> AgentRecallDeliveryRecordacknowledge_recall_delivery (method)
Section titled “acknowledge_recall_delivery (method)”async SQLiteAgentWorkContextStore.acknowledge_recall_delivery(claim: AgentRecallDeliveryClaim, *, acknowledgement_id: str, evidence_kind: AgentRecallDeliveryEvidenceKind, evidence_ref: str, acknowledged_at: datetime) -> AgentRecallDeliveryRecordpublish_recall_subscription (method)
Section titled “publish_recall_subscription (method)”async SQLiteAgentWorkContextStore.publish_recall_subscription(subscription: AgentRecallSubscription, *, expected_revision: int | None) -> AgentRecallSubscriptionPublicationReceiptload_recall_subscription (method)
Section titled “load_recall_subscription (method)”async SQLiteAgentWorkContextStore.load_recall_subscription(subscription_id: str, *, revision: int | None=None) -> AgentRecallSubscription | Noneclaim_due_recall_subscription (method)
Section titled “claim_due_recall_subscription (method)”async SQLiteAgentWorkContextStore.claim_due_recall_subscription(key: AgentRecallCheckpointKey, *, claim_id: str, runner_id: str, lease_seconds: float) -> AgentRecallSubscriptionRecord | Nonerenew_recall_subscription (method)
Section titled “renew_recall_subscription (method)”async SQLiteAgentWorkContextStore.renew_recall_subscription(claim: AgentRecallSubscriptionClaim, *, lease_seconds: float) -> AgentRecallSubscriptionRecordrelease_recall_subscription (method)
Section titled “release_recall_subscription (method)”async SQLiteAgentWorkContextStore.release_recall_subscription(claim: AgentRecallSubscriptionClaim, *, release_id: str, reason: str, released_at: datetime) -> AgentRecallSubscriptionRecordcommit_recall_subscription_evaluation (method)
Section titled “commit_recall_subscription_evaluation (method)”async SQLiteAgentWorkContextStore.commit_recall_subscription_evaluation(claim: AgentRecallSubscriptionClaim, result, *, evaluation_id: str, delivery_id: str | None, staged_by: str, evaluated_at: datetime) -> AgentRecallSubscriptionEvaluationload_recall_subscription_evaluation (method)
Section titled “load_recall_subscription_evaluation (method)”async SQLiteAgentWorkContextStore.load_recall_subscription_evaluation(evaluation_id: str) -> AgentRecallSubscriptionEvaluation | Noneclaim_recall_subscription_wake (method)
Section titled “claim_recall_subscription_wake (method)”async SQLiteAgentWorkContextStore.claim_recall_subscription_wake(key: AgentRecallCheckpointKey, *, claim_id: str, runner_id: str, lease_seconds: float) -> AgentRecallSubscriptionWake | Noneload_recall_subscription_wake (method)
Section titled “load_recall_subscription_wake (method)”async SQLiteAgentWorkContextStore.load_recall_subscription_wake(wake_id: str) -> AgentRecallSubscriptionWake | Nonerenew_recall_subscription_wake (method)
Section titled “renew_recall_subscription_wake (method)”async SQLiteAgentWorkContextStore.renew_recall_subscription_wake(claim: AgentRecallSubscriptionWakeClaim, *, lease_seconds: float) -> AgentRecallSubscriptionWakerelease_recall_subscription_wake (method)
Section titled “release_recall_subscription_wake (method)”async SQLiteAgentWorkContextStore.release_recall_subscription_wake(claim: AgentRecallSubscriptionWakeClaim, *, release_id: str, reason: str, released_at: datetime) -> AgentRecallSubscriptionWakeacknowledge_recall_subscription_wake (method)
Section titled “acknowledge_recall_subscription_wake (method)”async SQLiteAgentWorkContextStore.acknowledge_recall_subscription_wake(claim: AgentRecallSubscriptionWakeClaim, *, acknowledgement_id: str, acknowledged_at: datetime) -> AgentRecallSubscriptionWakeclose (method)
Section titled “close (method)”async SQLiteAgentWorkContextStore.close() -> Noneinit (method)
Section titled “init (method)”SQLiteAgentWorkContextStore.__init__(path: str | Path, *, schema_mode: schema.SchemaMode=schema.SchemaMode.CREATE, clock=None) -> None