cayu.storage.PostgresAgentWorkContextStore
Part of cayu.storage.postgres. Read the Python API overview and install the required extra.
from cayu.storage import PostgresAgentWorkContextStorePostgreSQL work-context/checkpoint store with transaction-fenced CAS.
Bases: _PostgresStoreBase, AgentWorkContextStore.
init (method)
Section titled “init (method)”PostgresAgentWorkContextStore.__init__(conninfo: str | None=None, *, pool: AsyncConnectionPool | None=None, min_size: int=1, max_size: int=8, schema_mode: schema.SchemaMode=schema.SchemaMode.VALIDATE, clock: Callable[[], datetime] | None=None) -> Noneensure_schema (method)
Section titled “ensure_schema (method)”async PostgresAgentWorkContextStore.ensure_schema() -> NoneOpen the pool and reconcile the schema now (per schema_mode).
Normally reconciliation happens lazily on first use; the cayu storage
CLI calls this to run a migrate (or validate) as an explicit step.
close (method)
Section titled “close (method)”async PostgresAgentWorkContextStore.close() -> NoneRelease store-owned resources, if any.
publish_work_context (method)
Section titled “publish_work_context (method)”async PostgresAgentWorkContextStore.publish_work_context(context: AgentWorkContext, *, expected_revision: int | None) -> AgentWorkContextPublicationReceiptload_work_context (method)
Section titled “load_work_context (method)”async PostgresAgentWorkContextStore.load_work_context(task_id: str, *, revision: int | None=None) -> AgentWorkContext | Noneload_work_context_publication (method)
Section titled “load_work_context_publication (method)”async PostgresAgentWorkContextStore.load_work_context_publication(operation_id: str) -> AgentWorkContextPublicationReceipt | Noneadvance_recall_checkpoint (method)
Section titled “advance_recall_checkpoint (method)”async PostgresAgentWorkContextStore.advance_recall_checkpoint(checkpoint: AgentRecallCheckpoint, *, expected_revision: int | None) -> AgentRecallCheckpointload_recall_checkpoint (method)
Section titled “load_recall_checkpoint (method)”async PostgresAgentWorkContextStore.load_recall_checkpoint(key: AgentRecallCheckpointKey, *, revision: int | None=None) -> AgentRecallCheckpoint | Nonestage_recall_delivery (method)
Section titled “stage_recall_delivery (method)”async PostgresAgentWorkContextStore.stage_recall_delivery(delivery: AgentRecallDelivery) -> AgentRecallDeliveryRecordload_recall_delivery (method)
Section titled “load_recall_delivery (method)”async PostgresAgentWorkContextStore.load_recall_delivery(delivery_id: str) -> AgentRecallDeliveryRecord | Noneclaim_recall_delivery (method)
Section titled “claim_recall_delivery (method)”async PostgresAgentWorkContextStore.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 PostgresAgentWorkContextStore.renew_recall_delivery(claim: AgentRecallDeliveryClaim, *, lease_seconds: float) -> AgentRecallDeliveryRecordrelease_recall_delivery (method)
Section titled “release_recall_delivery (method)”async PostgresAgentWorkContextStore.release_recall_delivery(claim: AgentRecallDeliveryClaim, *, release_id: str, reason: str, released_at: datetime) -> AgentRecallDeliveryRecordacknowledge_recall_delivery (method)
Section titled “acknowledge_recall_delivery (method)”async PostgresAgentWorkContextStore.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 PostgresAgentWorkContextStore.publish_recall_subscription(subscription: AgentRecallSubscription, *, expected_revision: int | None) -> AgentRecallSubscriptionPublicationReceiptload_recall_subscription (method)
Section titled “load_recall_subscription (method)”async PostgresAgentWorkContextStore.load_recall_subscription(subscription_id: str, *, revision: int | None=None) -> AgentRecallSubscription | Noneclaim_due_recall_subscription (method)
Section titled “claim_due_recall_subscription (method)”async PostgresAgentWorkContextStore.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 PostgresAgentWorkContextStore.renew_recall_subscription(claim: AgentRecallSubscriptionClaim, *, lease_seconds: float) -> AgentRecallSubscriptionRecordrelease_recall_subscription (method)
Section titled “release_recall_subscription (method)”async PostgresAgentWorkContextStore.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 PostgresAgentWorkContextStore.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 PostgresAgentWorkContextStore.load_recall_subscription_evaluation(evaluation_id: str) -> AgentRecallSubscriptionEvaluation | Noneclaim_recall_subscription_wake (method)
Section titled “claim_recall_subscription_wake (method)”async PostgresAgentWorkContextStore.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 PostgresAgentWorkContextStore.load_recall_subscription_wake(wake_id: str) -> AgentRecallSubscriptionWake | Nonerenew_recall_subscription_wake (method)
Section titled “renew_recall_subscription_wake (method)”async PostgresAgentWorkContextStore.renew_recall_subscription_wake(claim: AgentRecallSubscriptionWakeClaim, *, lease_seconds: float) -> AgentRecallSubscriptionWakerelease_recall_subscription_wake (method)
Section titled “release_recall_subscription_wake (method)”async PostgresAgentWorkContextStore.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 PostgresAgentWorkContextStore.acknowledge_recall_subscription_wake(claim: AgentRecallSubscriptionWakeClaim, *, acknowledgement_id: str, acknowledged_at: datetime) -> AgentRecallSubscriptionWake