cayu.sessions.InMemorySessionStore
Part of cayu.sessions.base. Read the Python API overview and install the required extra.
from cayu.sessions import InMemorySessionStoreIn-process session store for tests, local development, and examples.
Decorators: @model_store_surface('sessions').
Bases: MemoryExternalWaitMixin, MemorySessionExecutionMixin, MemoryCreationFenceMixin, SessionStore.
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 |
|---|---|---|
supports_session_execution |
class attribute |
False |
service_durability |
RuntimeStoreDurability |
RuntimeStoreDurability.DEVELOPMENT |
inspect_session_execution (method)
Section titled “inspect_session_execution (method)”async InMemorySessionStore.inspect_session_execution(session_id: str) -> SessionExecutionStateRead observational liveness; custom stores without leases return unknown.
list_pending_session_creations (method)
Section titled “list_pending_session_creations (method)”async InMemorySessionStore.list_pending_session_creations(owner, *, cursor=None, limit=32)read_session_creation_decision (method)
Section titled “read_session_creation_decision (method)”async InMemorySessionStore.read_session_creation_decision(target)create_participant_owned_session (method)
Section titled “create_participant_owned_session (method)”async InMemorySessionStore.create_participant_owned_session(creation_request: ParticipantSessionCreationRequest, *, resolved_request: RunRequest, identity: SessionIdentity, binding_factory: Callable[[Session], tuple[ParticipantSessionBinding, ParticipantSessionCreationReceipt]], recipient_provenance: object | None=None, recipient_selection: _ContextViewSelectionReceipt | None=None, creation_target=None, recipient_receipt_validator=None) -> tuple[Session, ParticipantSessionCreationReceipt]load_participant_session_binding (method)
Section titled “load_participant_session_binding (method)”async InMemorySessionStore.load_participant_session_binding(session_id: str) -> ParticipantSessionBinding | Noneload_participant_session_creation_receipt (method)
Section titled “load_participant_session_creation_receipt (method)”async InMemorySessionStore.load_participant_session_creation_receipt(session_id: str) -> ParticipantSessionCreationReceipt | Nonelookup_participant_session_creation (method)
Section titled “lookup_participant_session_creation (method)”async InMemorySessionStore.lookup_participant_session_creation(creation_request: ParticipantSessionCreationRequest) -> tuple[Session, ParticipantSessionCreationReceipt] | Nonecapture_context_view_publication_source (method)
Section titled “capture_context_view_publication_source (method)”async InMemorySessionStore.capture_context_view_publication_source(session_id: str) -> ContextViewPublicationSourcecapture_recipient_continuation (method)
Section titled “capture_recipient_continuation (method)”async InMemorySessionStore.capture_recipient_continuation(session_id: str) -> RecipientContinuationSelectionSelect exact identity without acquiring a writer or execution authority.
Wrappers must independently qualify this coherent native read. Inheriting an implementation is not evidence that wrapper-specific state is covered.
publish_context_view (method)
Section titled “publish_context_view (method)”async InMemorySessionStore.publish_context_view(manifest: _ContextViewManifest, *, publication_key: str) -> _ContextViewManifestlookup_context_view_selection (method)
Section titled “lookup_context_view_selection (method)”async InMemorySessionStore.lookup_context_view_selection(selection_key: str)lookup_context_view_publication (method)
Section titled “lookup_context_view_publication (method)”async InMemorySessionStore.lookup_context_view_publication(publication_key: str) -> _ContextViewManifest | Noneselect_context_view (method)
Section titled “select_context_view (method)”async InMemorySessionStore.select_context_view(request: _ContextViewSelectionRequest) -> _ContextViewSelectionReceiptread_context_view_selection_decision (method)
Section titled “read_context_view_selection_decision (method)”async InMemorySessionStore.read_context_view_selection_decision(request)read_context_view (method)
Section titled “read_context_view (method)”async InMemorySessionStore.read_context_view(view_id: str, *, source_session_id: str) -> _ContextViewReadbacktransition_context_view_ownership (method)
Section titled “transition_context_view_ownership (method)”async InMemorySessionStore.transition_context_view_ownership(request: _ContextViewOwnershipRequest) -> _ContextViewSelectionReceiptvalidate_context_view_source_closure (method)
Section titled “validate_context_view_source_closure (method)”async InMemorySessionStore.validate_context_view_source_closure(session_id: str) -> Nonevalidate_context_view_compaction (method)
Section titled “validate_context_view_compaction (method)”async InMemorySessionStore.validate_context_view_compaction(session_id: str, expected_transcript_cursor: int) -> Noneread_context_view_lifecycle_events (method)
Section titled “read_context_view_lifecycle_events (method)”async InMemorySessionStore.read_context_view_lifecycle_events(view_id: str, *, limit: int=256, owner_participant: _ParticipantRef | None=None) -> tuple[_ContextViewLifecycleEvent, ...]durable_state_paths (method)
Section titled “durable_state_paths (method)”InMemorySessionStore.durable_state_paths() -> tuple[Path, ...]Return local files that own this store’s durable state.
In-memory and remote stores return no paths. Filesystem-confined features must fail closed when the store cannot provide this evidence; custom local stores can opt in by overriding this method.
public_authority_alias_codec (property)
Section titled “public_authority_alias_codec (property)”InMemorySessionStore.public_authority_alias_codec() -> PublicAuthorityAliasCodecregister_public_authority_alias (method)
Section titled “register_public_authority_alias (method)”async InMemorySessionStore.register_public_authority_alias(public_alias: str, *, field_name: str, private_value: str, scope_session_id: str | None=None) -> Noneresolve_public_authority_alias (method)
Section titled “resolve_public_authority_alias (method)”async InMemorySessionStore.resolve_public_authority_alias(public_alias: str, *, field_name: str, scope_session_id: str | None=None) -> str | Nonepublic_authority_private_value_exists (method)
Section titled “public_authority_private_value_exists (method)”async InMemorySessionStore.public_authority_private_value_exists(private_value: str, *, field_name: str, scope_session_id: str | None=None) -> boolissue_targeted_tool_grants (method)
Section titled “issue_targeted_tool_grants (method)”async InMemorySessionStore.issue_targeted_tool_grants(session_id: str, *, expected_run_epoch: int, records: tuple[TargetedToolGrantRecord, ...], events: tuple[Event, ...]) -> TargetedToolGrantIssueResultlist_targeted_tool_grants (method)
Section titled “list_targeted_tool_grants (method)”async InMemorySessionStore.list_targeted_tool_grants(session_id: str, *, interaction_id: str | None=None, limit: int=TARGETED_TOOL_GRANT_INSPECTION_MAX_RECORDS) -> tuple[TargetedToolGrantRecord, ...]load_targeted_tool_grant_state (method)
Section titled “load_targeted_tool_grant_state (method)”async InMemorySessionStore.load_targeted_tool_grant_state(session_id: str) -> TargetedToolGrantStateSnapshotbind_targeted_tool_grant_use (method)
Section titled “bind_targeted_tool_grant_use (method)”async InMemorySessionStore.bind_targeted_tool_grant_use(request: TargetedToolUseRequest, *, observed_at: datetime) -> TargetedToolUseResultrevoke_targeted_tool_grant (method)
Section titled “revoke_targeted_tool_grant (method)”async InMemorySessionStore.revoke_targeted_tool_grant(tool_ref: str, *, session_id: str, expected_run_epoch: int, reason: str, revoked_at: datetime) -> TargetedToolGrantRecord | Nonereconstruct_targeted_tool_grants (method)
Section titled “reconstruct_targeted_tool_grants (method)”async InMemorySessionStore.reconstruct_targeted_tool_grants(session_id: str, *, expected_run_epoch: int, interaction_id: str, generation_id: str, agent_name: str, task_id: str | None, environment_name: str | None, principal: str | None, tenant: str | None, catalogue_revision: str, descriptors_by_id: Mapping[str, tuple[str, str, str]], capability_ceiling_names: frozenset[str], observed_at: datetime) -> TargetedToolGrantReconstructionResultcreate (method)
Section titled “create (method)”async InMemorySessionStore.create(request: RunRequest, *, identity: SessionIdentity, interaction_started_event: Event | None=None, interaction_source_messages: list[Message] | None=None, checkpoint_transform: CheckpointTransform | None=None, result_checkpoint_transform: CheckpointTransform | None=None, operation_initializer: SessionOperationInitializer | None=None, participant_binding_factory: Callable[[Session], tuple[ParticipantSessionBinding, ParticipantSessionCreationReceipt]] | None=None, participant_request_commitment: str | None=None, participant_provenance: object | None=None, recipient_selection: _ContextViewSelectionReceipt | None=None, creation_target=None, recipient_receipt_validator: Callable[[Session, ParticipantSessionCreationReceipt], object] | None=None) -> Sessioncreate_fork (method)
Section titled “create_fork (method)”async InMemorySessionStore.create_fork(*, source_session_id: str, fork: Session, source_statuses: set[SessionStatus], transcript_cursor: int | None, checkpoint_transform: CheckpointTransform | None, system_prompt_replacement: ForkSystemPromptReplacement | None=None, expected_source_run_epoch: int, operation_initializer: SessionOperationInitializer | None=None) -> Sessioncreate_fork_with_transcript_validation (method)
Section titled “create_fork_with_transcript_validation (method)”async InMemorySessionStore.create_fork_with_transcript_validation(*, source_session_id: str, fork: Session, source_statuses: set[SessionStatus], transcript_cursor: int | None, checkpoint_transform: CheckpointTransform | None, system_prompt_replacement: ForkSystemPromptReplacement | None=None, expected_source_run_epoch: int, transcript_validator: ForkTranscriptValidator, operation_initializer: SessionOperationInitializer | None=None) -> Sessioncreate_profiled_fork (method)
Section titled “create_profiled_fork (method)”async InMemorySessionStore.create_profiled_fork(*, source_session_id: str, fork: Session, source_statuses: set[SessionStatus], transcript_cursor: int | None, checkpoint_transform: CheckpointTransform | None, system_prompt_replacement: ForkSystemPromptReplacement | None=None, expected_source_run_epoch: int, relationship: SessionForkProfileRelationship, events: list[Event], transcript_validator: ForkTranscriptValidator | None=None, checkpoint_authority_decoder: ForkCheckpointAuthorityDecoder | None=None, operation_initializer: SessionOperationInitializer | None=None) -> ProfiledSessionForkResultload (method)
Section titled “load (method)”async InMemorySessionStore.load(session_id: str) -> Session | Noneload_state (method)
Section titled “load_state (method)”async InMemorySessionStore.load_state(session_id: str) -> SessionStateSnapshot | Noneload_invocation_snapshot (method)
Section titled “load_invocation_snapshot (method)”async InMemorySessionStore.load_invocation_snapshot(session_id: str) -> SessionInvocationSnapshot | Noneinspect_identity (method)
Section titled “inspect_identity (method)”async InMemorySessionStore.inspect_identity(session_id: str) -> SessionInspectionIdentityupdate_status (method)
Section titled “update_status (method)”async InMemorySessionStore.update_status(session_id: str, status: SessionStatus) -> Sessiontransition_status (method)
Section titled “transition_status (method)”async InMemorySessionStore.transition_status(session_id: str, *, from_statuses: set[SessionStatus], to_status: SessionStatus) -> Sessiontransition_status_and_checkpoint (method)
Section titled “transition_status_and_checkpoint (method)”async InMemorySessionStore.transition_status_and_checkpoint(session_id: str, *, from_statuses: set[SessionStatus], to_status: SessionStatus, checkpoint_transform: CheckpointTransform | None=None, store_time_checkpoint_transform: StoreTimeCheckpointTransform | None=None, result_checkpoint_transform: CheckpointTransform | None=None, interaction_started_event: Event | None=None, interaction_source_messages: list[Message] | None=None, continued_interaction_id: str | None=None, defer_interaction_source: bool=False, model_transition: SessionModelTransition | None=None, execution_profile: ExecutionProfileIdentity | None=None, execution_profile_decision: ExecutionProfileDecision | None=None, adopted_runtime_identity: SessionRuntimeIdentity | None=None, tool_capability_ceiling: ToolCapabilityCeiling | None=None, expected_latest_interaction_event_id: str | None=None, require_no_active_model_completion_dispatch: bool=False, temporary_service_admission: TemporaryServiceAdmission | None=None) -> Sessionadmit_execution_profile_resume (method)
Section titled “admit_execution_profile_resume (method)”async InMemorySessionStore.admit_execution_profile_resume(session_id: str, *, from_statuses: set[SessionStatus], to_status: SessionStatus, checkpoint_transform: CheckpointTransform | None=None, store_time_checkpoint_transform: StoreTimeCheckpointTransform | None=None, result_checkpoint_transform: CheckpointTransform | None=None, execution_profile: ExecutionProfileIdentity, tool_capability_ceiling: ToolCapabilityCeiling | None=None, execution_profile_decision: ExecutionProfileDecision | None=None, adopted_runtime_identity: SessionRuntimeIdentity | None=None, interaction_started_event: Event | None=None, interaction_source_messages: list[Message] | None=None, continued_interaction_id: str | None=None, defer_interaction_source: bool=False, model_transition: SessionModelTransition | None=None, temporary_service_admission: TemporaryServiceAdmission | None=None) -> SessionAtomically compare a profile through the normal resume transition.
admit_session_invocation (method)
Section titled “admit_session_invocation (method)”async InMemorySessionStore.admit_session_invocation(session_id: str, *, admission: SessionInvocationAdmission) -> SessionAtomically claim one valid profiled invocation and its interaction.
apply_invocation_lifecycle_command (method)
Section titled “apply_invocation_lifecycle_command (method)”async InMemorySessionStore.apply_invocation_lifecycle_command(command: object) -> objectApply one command only after authenticating the store protocol.
settle_session_invocation (method)
Section titled “settle_session_invocation (method)”async InMemorySessionStore.settle_session_invocation(command: Any) -> InteractionTransitionResultrelease_session_invocation (method)
Section titled “release_session_invocation (method)”async InMemorySessionStore.release_session_invocation(command: Any) -> Anyreject_execution_profile_resume (method)
Section titled “reject_execution_profile_resume (method)”async InMemorySessionStore.reject_execution_profile_resume(session_id: str, *, expected_session_instance_id: str | None=None, expected_statuses: set[SessionStatus], expected_run_epoch: int, expected_profile: ExecutionProfileIdentity, candidate_profile: ExecutionProfileIdentity, event: Event, decision: ExecutionProfileDecision | None=None, expected_active_invocation_profile_authority: CheckpointValueAuthority | None=None) -> ExecutionProfileRejectionResultreject_active_invocation_execution_profile (method)
Section titled “reject_active_invocation_execution_profile (method)”async InMemorySessionStore.reject_active_invocation_execution_profile(session_id: str, *, expected_session_instance_id: str | None=None, expected_statuses: set[SessionStatus], expected_run_epoch: int, expected_active_invocation_profile: ActiveInvocationExecutionProfile, candidate_profile: ExecutionProfileIdentity, event: Event, decision: ExecutionProfileDecision | None=None) -> ExecutionProfileRejectionResultAtomically compare checkpoint authority and reject changed continuation.
transition_status_if_no_queued_messages (method)
Section titled “transition_status_if_no_queued_messages (method)”async InMemorySessionStore.transition_status_if_no_queued_messages(session_id: str, *, from_statuses: set[SessionStatus], to_status: SessionStatus, checkpoint_mutation: dict[str, Any] | None=None) -> Sessionpublish_interaction_transition (method)
Section titled “publish_interaction_transition (method)”async InMemorySessionStore.publish_interaction_transition(session_id: str, *, event: Event, from_statuses: set[SessionStatus], to_status: SessionStatus, only_if_no_queued_messages: bool=False, model_completion_stage_settlement: ModelCompletionStageSettlementRequest | None=None, checkpoint_mutation: dict[str, Any] | None=None, terminal_event: Event | None=None, terminal_decision: InvocationTerminalDecision | None=None, expected_session_instance_id: str | None=None, expected_active_invocation_profile: ActiveInvocationExecutionProfile | None=None, expected_invocation_authority_state: Literal['active', 'released']='active', expected_recovery_claim_id: str | None=None, terminalization_only: bool=False, terminalization_plan_ownership: Any=None) -> InteractionTransitionResultload_interaction_transition_receipt (method)
Section titled “load_interaction_transition_receipt (method)”async InMemorySessionStore.load_interaction_transition_receipt(session_id: str, *, transition: InteractionTransitionSpec, expected_recovery_claim_id: str | None=None) -> InteractionTransitionReceiptResult | Noneload_historical_interaction_settlement (method)
Section titled “load_historical_interaction_settlement (method)”async InMemorySessionStore.load_historical_interaction_settlement(session_id: str, *, expected_session_instance_id: str, expected_event: Event, expected_profile: ExecutionProfileIdentity) -> InteractionTransitionReceiptResultRead exact prior settlement evidence without granting run authority.
Unlike invocation release lookup, this permits a later current epoch. It cannot release a fence or authorize a historical invocation: callers must separately acquire their own execution or mutation authority.
load_invocation_settlement_transition (method)
Section titled “load_invocation_settlement_transition (method)”async InMemorySessionStore.load_invocation_settlement_transition(session_id: str, *, expected_session_instance_id: str, expected_active_invocation_profile: ActiveInvocationExecutionProfile) -> InteractionTransitionSpec | NoneResolve exact terminal settlement for one active invocation.
Event lookup is bounded and supplies only the receipt identity. The backend authenticates the complete stored receipt and its invocation tuple before returning the transition. Release compares the same receipt again inside its mutation transaction.
fence_stalled_run (method)
Section titled “fence_stalled_run (method)”async InMemorySessionStore.fence_stalled_run(session_id: str, *, statuses: set[SessionStatus], inactive_for_seconds: int) -> Session | Nonereserve_stalled_run_recovery (method)
Section titled “reserve_stalled_run_recovery (method)”async InMemorySessionStore.reserve_stalled_run_recovery(session_id: str, *, statuses: set[SessionStatus], inactive_for_seconds: int | None, checkpoint_transform: StoreTimeCheckpointTransform) -> Session | Nonefence_run_and_transform_checkpoint (method)
Section titled “fence_run_and_transform_checkpoint (method)”async InMemorySessionStore.fence_run_and_transform_checkpoint(session_id: str, *, statuses: set[SessionStatus], checkpoint_transform: CheckpointTransform, result_checkpoint_transform: CheckpointTransform | None=None) -> Sessionrelease_run_fence (method)
Section titled “release_run_fence (method)”async InMemorySessionStore.release_run_fence(session_id: str) -> Noneclaim_budget_reservation_identity (method)
Section titled “claim_budget_reservation_identity (method)”async InMemorySessionStore.claim_budget_reservation_identity(*, reservation_id: str, publication_session_id: str, publication_id: str) -> Noneappend_event (method)
Section titled “append_event (method)”async InMemorySessionStore.append_event(session_id: str, event: Event) -> Noneappend_events (method)
Section titled “append_events (method)”async InMemorySessionStore.append_events(session_id: str, events: list[Event]) -> Noneappend_workflow_step_started (method)
Section titled “append_workflow_step_started (method)”async InMemorySessionStore.append_workflow_step_started(session_id: str, event: Event, *, workflow_name: str, attempt_id: str) -> boolappend_tool_effect_conflict (method)
Section titled “append_tool_effect_conflict (method)”async InMemorySessionStore.append_tool_effect_conflict(request: object) -> Eventload_mcp_manifest_baselines (method)
Section titled “load_mcp_manifest_baselines (method)”async InMemorySessionStore.load_mcp_manifest_baselines(history_keys: tuple[str, ...]) -> McpManifestBaselineLoadResultcompare_and_publish_mcp_manifest_checks (method)
Section titled “compare_and_publish_mcp_manifest_checks (method)”async InMemorySessionStore.compare_and_publish_mcp_manifest_checks(session_id: str, *, expected_generations: dict[str, int | None], baseline_updates: dict[str, McpManifestBaseline], events: list[Event]) -> McpManifestPublicationResultclaim_persisted_event_side_effect (method)
Section titled “claim_persisted_event_side_effect (method)”async InMemorySessionStore.claim_persisted_event_side_effect(*, session_id: str | None=None, event_id: str | None=None, lease_seconds: float=300.0) -> PersistedEventSideEffectClaim | Noneget_persisted_event_side_effect_delivery (method)
Section titled “get_persisted_event_side_effect_delivery (method)”async InMemorySessionStore.get_persisted_event_side_effect_delivery(*, session_id: str, event_id: str) -> PersistedEventSideEffectDelivery | Noneclaim_first_persisted_event_side_effect (method)
Section titled “claim_first_persisted_event_side_effect (method)”async InMemorySessionStore.claim_first_persisted_event_side_effect(expected: PersistedEventSideEffectDelivery) -> PersistedEventSideEffectClaim | Noneretire_failed_first_event_delivery (method)
Section titled “retire_failed_first_event_delivery (method)”async InMemorySessionStore.retire_failed_first_event_delivery(expected: PersistedEventSideEffectDelivery) -> PersistedEventSideEffectDelivery | Nonemark_persisted_event_side_effect_delivered (method)
Section titled “mark_persisted_event_side_effect_delivered (method)”async InMemorySessionStore.mark_persisted_event_side_effect_delivered(claim: PersistedEventSideEffectClaim) -> PersistedEventSideEffectDeliverymark_persisted_event_side_effect_failed (method)
Section titled “mark_persisted_event_side_effect_failed (method)”async InMemorySessionStore.mark_persisted_event_side_effect_failed(claim: PersistedEventSideEffectClaim, *, error: str, max_attempts: int, retry_delay_seconds: float) -> PersistedEventSideEffectDeliverylist_persisted_event_side_effect_deliveries (method)
Section titled “list_persisted_event_side_effect_deliveries (method)”async InMemorySessionStore.list_persisted_event_side_effect_deliveries(*, statuses: set[PersistedEventSideEffectStatus] | None=None, claimable_only: bool=False, after_sequence: int | None=None, limit: int=100) -> list[PersistedEventSideEffectDelivery]get_persisted_event_side_effect_health (method)
Section titled “get_persisted_event_side_effect_health (method)”async InMemorySessionStore.get_persisted_event_side_effect_health() -> PersistedEventSideEffectHealthquery_persisted_event_side_effect_deliveries (method)
Section titled “query_persisted_event_side_effect_deliveries (method)”async InMemorySessionStore.query_persisted_event_side_effect_deliveries(query: PersistedEventSideEffectQuery) -> PersistedEventSideEffectPagedefer_persisted_event_side_effect (method)
Section titled “defer_persisted_event_side_effect (method)”async InMemorySessionStore.defer_persisted_event_side_effect(claim: PersistedEventSideEffectClaim) -> PersistedEventSideEffectDeliveryrenew_persisted_event_side_effect (method)
Section titled “renew_persisted_event_side_effect (method)”async InMemorySessionStore.renew_persisted_event_side_effect(claim: PersistedEventSideEffectClaim, *, lease_seconds: float=300.0) -> PersistedEventSideEffectDeliveryenqueue_session_message (method)
Section titled “enqueue_session_message (method)”async InMemorySessionStore.enqueue_session_message(request: EnqueueSessionMessageRequest, *, expected_authorized_target_instance_id: str | None=None) -> EnqueueSessionMessageResultappend_peer_content (method)
Section titled “append_peer_content (method)”async InMemorySessionStore.append_peer_content(request: PeerContentAppendRequest, *, qualify_target: Callable[[Session], None] | None=None, pending_transcript_cursor: int | None=None) -> PeerContentReceiptread_peer_content (method)
Section titled “read_peer_content (method)”async InMemorySessionStore.read_peer_content(append_key: PeerAppendKey) -> PeerContentReceipt | Noneexclude_peer_content (method)
Section titled “exclude_peer_content (method)”async InMemorySessionStore.exclude_peer_content(request: PeerContentAppendRequest, *, reason: str) -> PeerContentReceiptread_peer_content_attempt (method)
Section titled “read_peer_content_attempt (method)”async InMemorySessionStore.read_peer_content_attempt(request: PeerContentAppendRequest) -> PeerContentReceipt | Nonelist_pending_peer_content (method)
Section titled “list_pending_peer_content (method)”async InMemorySessionStore.list_pending_peer_content(*, after_operation_key=None, limit=32)Trusted receiving-owner discovery, independent of creation settlement.
retry_pending_peer_content (method)
Section titled “retry_pending_peer_content (method)”async InMemorySessionStore.retry_pending_peer_content(session_id: str, *, expected_session_instance_id: str, expected_run_epoch: int, expected_transcript_cursor: int, admit=None) -> tuple[PeerContentReceipt, ...]record_peer_content_exposure (method)
Section titled “record_peer_content_exposure (method)”async InMemorySessionStore.record_peer_content_exposure(request: PeerContentExposureRequest) -> PeerContentExposureReceiptbegin_peer_content_exposure (method)
Section titled “begin_peer_content_exposure (method)”async InMemorySessionStore.begin_peer_content_exposure(request: PeerContentExposureRequest) -> PeerContentExposureReceiptread_peer_content_exposure (method)
Section titled “read_peer_content_exposure (method)”async InMemorySessionStore.read_peer_content_exposure(append_key: PeerAppendKey, exposure_id: str) -> PeerContentExposureReceipt | Noneinspect_session_messages (method)
Section titled “inspect_session_messages (method)”async InMemorySessionStore.inspect_session_messages(query: SessionMessageQuery, *, expected_authorized_session_instance_id: str | None=None) -> SessionMessageInspectionapply_session_message_action (method)
Section titled “apply_session_message_action (method)”async InMemorySessionStore.apply_session_message_action(request: SessionMessageActionRequest) -> SessionMessageActionResultsnapshot_session_message_source (method)
Section titled “snapshot_session_message_source (method)”async InMemorySessionStore.snapshot_session_message_source(session_id: str, *, include_transcript_digest: bool=False, include_checkpoint_digest: bool=False, expected_authorized_session_instance_id: str | None=None) -> SessionMessageSourcedeliver_queued_session_messages (method)
Section titled “deliver_queued_session_messages (method)”async InMemorySessionStore.deliver_queued_session_messages(session_id: str, *, include_on_idle: bool, delivery_id: str | None=None, eligible_through: int | None=None, limit: int=SESSION_MESSAGE_DELIVERY_BATCH_LIMIT, interaction_id: str | None=None, interaction_started_event: Event | None=None, profile_handoff: QueuedInteractionProfileHandoff | None=None, reject_only: bool=False) -> SessionMessageDeliveryBatchrepair_queued_interaction_profile_handoff (method)
Section titled “repair_queued_interaction_profile_handoff (method)”async InMemorySessionStore.repair_queued_interaction_profile_handoff(session_id: str, *, interaction_started_event: Event, profile_handoff: QueuedInteractionProfileHandoff) -> ActiveInvocationExecutionProfilepublish_checkpoint_and_events (method)
Section titled “publish_checkpoint_and_events (method)”async InMemorySessionStore.publish_checkpoint_and_events(session_id: str, *, checkpoint_transform: CheckpointTransform, events: list[Event], expected_statuses: set[SessionStatus] | None=None, expected_run_epoch: int | None=None, expected_transcript_cursor: int | None=None) -> Sessionpublish_checkpoint_and_events_with_store_time (method)
Section titled “publish_checkpoint_and_events_with_store_time (method)”async InMemorySessionStore.publish_checkpoint_and_events_with_store_time(session_id: str, *, idempotency_key: str, checkpoint_transform: StoreTimeCheckpointTransform, commit_time_guard: Callable[[datetime], None], events: list[Event], expected_statuses: set[SessionStatus] | None=None, expected_run_epoch: int | None=None, expected_transcript_cursor: int | None=None) -> SessionPublish checkpoint state using the backend’s transactional clock.
load_session_operation (method)
Section titled “load_session_operation (method)”async InMemorySessionStore.load_session_operation(session_id: str, idempotency_key: str, *, checkpoint_root_guard: CheckpointRootFieldGuard | None=None) -> dict[str, Any] | Nonepublish_session_operation (method)
Section titled “publish_session_operation (method)”async InMemorySessionStore.publish_session_operation(session_id: str, *, idempotency_key: str, operation_transform: SessionOperationTransform, events: list[Event], expected_statuses: set[SessionStatus] | None=None, expected_run_epoch: int | None=None, expected_transcript_cursor: int | None=None) -> Sessionsupports_external_waits (method)
Section titled “supports_external_waits (method)”InMemorySessionStore.supports_external_waits() -> boolpublish_session_operation_guarded (method)
Section titled “publish_session_operation_guarded (method)”async InMemorySessionStore.publish_session_operation_guarded(session_id: str, *, idempotency_key: str, operation_transform: SessionOperationTransform, commit_guard: Callable[[], None], events: list[Event], expected_statuses: set[SessionStatus] | None=None, expected_run_epoch: int | None=None, expected_transcript_cursor: int | None=None) -> Sessionpublish_session_operation_guarded_with_store_time (method)
Section titled “publish_session_operation_guarded_with_store_time (method)”async InMemorySessionStore.publish_session_operation_guarded_with_store_time(session_id: str, *, idempotency_key: str, operation_transform: StoreTimeSessionOperationTransform, commit_guard: Callable[[], None], commit_time_guard: Callable[[datetime], None], events: list[Event], expected_statuses: set[SessionStatus] | None=None, expected_run_epoch: int | None=None, expected_transcript_cursor: int | None=None, context_view_compaction_cursor: int | None=None) -> Sessionprepare_continuation_ticket (method)
Section titled “prepare_continuation_ticket (method)”async InMemorySessionStore.prepare_continuation_ticket(command: ContinuationPreparation) -> ContinuationRecordAtomically retain one exact continuation ticket in ARMING state.
lookup_continuation_ticket (method)
Section titled “lookup_continuation_ticket (method)”async InMemorySessionStore.lookup_continuation_ticket(expected: ContinuationPreparation) -> ExactLookup[ContinuationRecord]Return exact retained preparation evidence, never infer an outcome.
load_continuation_ticket (method)
Section titled “load_continuation_ticket (method)”async InMemorySessionStore.load_continuation_ticket(session_id: str, *, registration_key: str, session_instance_id: str) -> ContinuationRecord | NoneRead one continuation aggregate without treating absence as proof.
mark_continuation_waiting (method)
Section titled “mark_continuation_waiting (method)”async InMemorySessionStore.mark_continuation_waiting(ticket: ContinuationTicket) -> ContinuationRecordPublish the ARMING-to-WAITING transition under the ticket’s CAS.
latch_continuation (method)
Section titled “latch_continuation (method)”async InMemorySessionStore.latch_continuation(latch: ContinuationLatch) -> ContinuationRecordPublish one immutable readiness latch, including an ARMING latch.
consume_continuation (method)
Section titled “consume_continuation (method)”async InMemorySessionStore.consume_continuation(consumption: ContinuationConsumption) -> ContinuationRecordAtomically elect one inline or queued continuation and replay it.
retire_continuation (method)
Section titled “retire_continuation (method)”async InMemorySessionStore.retire_continuation(retirement: ContinuationRetirement) -> ContinuationRecordAtomically retire a ticket, losing only to an already committed consume.
load_runtime_publication_receipt (method)
Section titled “load_runtime_publication_receipt (method)”async InMemorySessionStore.load_runtime_publication_receipt(session_id: str, publication_id: str) -> RuntimePublicationReceipt | NoneLoad and verify one store-owned runtime publication receipt.
publish_runtime_publication (method)
Section titled “publish_runtime_publication (method)”async InMemorySessionStore.publish_runtime_publication(session_id: str, *, request: RuntimePublicationRequest, expected_statuses: set[SessionStatus] | None=None, expected_run_epoch: int | None=None, expected_transcript_cursor: int | None=None) -> RuntimePublicationResultAtomically publish or exactly replay one logical runtime boundary.
load_model_completion_stage (method)
Section titled “load_model_completion_stage (method)”async InMemorySessionStore.load_model_completion_stage(session_id: str, stage_id: str) -> ModelCompletionStage | NoneLoad and verify append-only pre-dispatch and terminal completion evidence.
load_model_completion_stage_settlement (method)
Section titled “load_model_completion_stage_settlement (method)”async InMemorySessionStore.load_model_completion_stage_settlement(session_id: str, stage_id: str) -> ModelCompletionStageSettlement | NoneLoad verified terminal non-success evidence for one exact stage.
load_model_completion_stage_abandonment (method)
Section titled “load_model_completion_stage_abandonment (method)”async InMemorySessionStore.load_model_completion_stage_abandonment(session_id: str, stage_id: str) -> ModelCompletionStageAbandonment | NoneRead positive no-dispatch evidence after the preparation was removed.
This is a query, not permission to dispatch. Re-preparation compares the complete expected predecessor and this receipt in its own transaction. The shared operation-record lookup keeps all supported backends under their existing read owner; no second route cache is needed after restart.
load_active_model_completion_stage (method)
Section titled “load_active_model_completion_stage (method)”async InMemorySessionStore.load_active_model_completion_stage(session_id: str) -> ActiveModelCompletionStage | NoneLoad a verified snapshot of the dispatch currently eligible to publish.
load_model_completion_stage_dispatch (method)
Section titled “load_model_completion_stage_dispatch (method)”async InMemorySessionStore.load_model_completion_stage_dispatch(session_id: str, stage_id: str) -> ModelCompletionStageDispatch | NoneLoad exact evidence that a prepared stage crossed the dispatch fence.
mark_model_completion_stage_dispatched (method)
Section titled “mark_model_completion_stage_dispatched (method)”async InMemorySessionStore.mark_model_completion_stage_dispatched(session_id: str, *, stage: ModelCompletionStage, consume_child_session_notifications: bool=True) -> ModelCompletionStageDispatchDurably cross the last local fence before entering provider-controlled code.
prepare_model_completion_stage (method)
Section titled “prepare_model_completion_stage (method)”async InMemorySessionStore.prepare_model_completion_stage(session_id: str, *, request: ModelCompletionStageRequest, expected_statuses: set[SessionStatus], expected_run_epoch: int, expected_transcript_cursor: int) -> ModelCompletionStageResultInsert or replay a stage; dispatch only when the result explicitly authorizes it.
complete_recovered_model_completion_stage (method)
Section titled “complete_recovered_model_completion_stage (method)”async InMemorySessionStore.complete_recovered_model_completion_stage(session_id: str, *, stage_id: str, publication: RuntimePublicationRequest, recovery_fence: ModelCompletionStageRecoveryFence) -> ModelCompletionStageResultInsert synthetic auxiliary terminal evidence under an atomic recovery fence.
Backends overriding the atomic hook must explicitly attest this protocol. Ordinary provider completion continues through complete_model_completion_stage.
complete_model_completion_stage (method)
Section titled “complete_model_completion_stage (method)”async InMemorySessionStore.complete_model_completion_stage(session_id: str, *, stage_id: str, publication: RuntimePublicationRequest) -> ModelCompletionStageResultAppend or exactly replay immutable terminal provider-attempt material.
For auxiliary inference, terminal material records the explicit attempt outcome and accounting; it does not imply a successful model response.
abandon_model_completion_stage (method)
Section titled “abandon_model_completion_stage (method)”async InMemorySessionStore.abandon_model_completion_stage(session_id: str, *, stage_id: str, preparation_digest: str, expected_run_epoch: int, stage_source_run_epoch: int | None=None) -> ModelCompletionStageAbandonmentResultAtomically abandon one exact active stage before provider dispatch.
An exact replay reconstructs the durable abandonment tombstone. A later preparation of the same request receives a new preparation digest, so a delayed retry of an older abandonment can never clear it.
promote_model_completion_stage (method)
Section titled “promote_model_completion_stage (method)”async InMemorySessionStore.promote_model_completion_stage(session_id: str, *, stage_id: str, expected_run_epoch: int) -> RuntimePublicationResultAtomically verify and publish a terminal stage without a load/publish race.
load_session_export_snapshot (method)
Section titled “load_session_export_snapshot (method)”async InMemorySessionStore.load_session_export_snapshot(session_id: str, *, limits: SessionExportLimits | None=None) -> SessionExportSnapshot | Noneload_events (method)
Section titled “load_events (method)”async InMemorySessionStore.load_events(session_id: str) -> list[Event]load_user_input_supersession_events (method)
Section titled “load_user_input_supersession_events (method)”async InMemorySessionStore.load_user_input_supersession_events(session_id: str, input_id: str) -> list[Event]load_tool_round_lifecycle_events (method)
Section titled “load_tool_round_lifecycle_events (method)”async InMemorySessionStore.load_tool_round_lifecycle_events(session_id: str, tool_call_ids: list[str] | tuple[str, ...]) -> list[Event]load_tool_round_lifecycle_events_for_round (method)
Section titled “load_tool_round_lifecycle_events_for_round (method)”async InMemorySessionStore.load_tool_round_lifecycle_events_for_round(session_id: str, tool_call_ids: list[str] | tuple[str, ...], *, tool_round_identity: ToolRoundIdentity) -> list[Event]query_events (method)
Section titled “query_events (method)”async InMemorySessionStore.query_events(query: EventQuery | None=None) -> list[EventRecord]read_usage_accounting (method)
Section titled “read_usage_accounting (method)”async InMemorySessionStore.read_usage_accounting(query: EventQuery, *, by_session: bool=False, by_identity: bool=False) -> UsageAccountingSnapshotread_cost_accounting (method)
Section titled “read_cost_accounting (method)”async InMemorySessionStore.read_cost_accounting(query: EventQuery, pricing: PriceBook, *, currency: str='USD', details: bool=False, by_session: bool=False, additional_events: tuple[Event, ...]=(), max_detail_bytes: int | None=None, previous: CostAccountingSnapshot | None=None) -> CostAccountingSnapshotevent_exists (method)
Section titled “event_exists (method)”async InMemorySessionStore.event_exists(query: EventQuery) -> boolquery_events_bounded (method)
Section titled “query_events_bounded (method)”async InMemorySessionStore.query_events_bounded(query: EventQuery, *, max_bytes: int) -> list[EventRecord]load_bounded (method)
Section titled “load_bounded (method)”async InMemorySessionStore.load_bounded(session_id: str, *, max_bytes: int) -> Session | NoneLoad a full session only after bounding transport bytes in one snapshot.
export_terminal_session_evidence (method)
Section titled “export_terminal_session_evidence (method)”async InMemorySessionStore.export_terminal_session_evidence(session_id: str, *, spool: EvidenceSpool) -> NoneExport a stable terminal snapshot to bounded indexed backing.
Optional capability. Unsupported stores fail before reading payloads; callers must explicitly choose the separate bounded eager fallback.
load_terminal_session_evidence (method)
Section titled “load_terminal_session_evidence (method)”async InMemorySessionStore.load_terminal_session_evidence(session_id: str, *, limits: TerminalSessionEvidenceLimits | None=None) -> TerminalSessionEvidenceload_runner_owned_interrupted_evidence (method)
Section titled “load_runner_owned_interrupted_evidence (method)”async InMemorySessionStore.load_runner_owned_interrupted_evidence(session_id: str, *, observed_events: tuple[RunnerObservedEventIdentity, ...] | None=None, expected_parent_session_id: str | None=None, limits: TerminalSessionEvidenceLimits | None=None) -> TerminalSessionEvidencequery_latest_interaction_events (method)
Section titled “query_latest_interaction_events (method)”async InMemorySessionStore.query_latest_interaction_events(session_id: str, *, before_sequence: int | None=None, limit: int=100) -> list[EventRecord]summarize_events (method)
Section titled “summarize_events (method)”async InMemorySessionStore.summarize_events(session_id: str) -> EventSummarysummarize_outcome (method)
Section titled “summarize_outcome (method)”async InMemorySessionStore.summarize_outcome(session_id: str) -> SessionOutcomeinspect_summary (method)
Section titled “inspect_summary (method)”async InMemorySessionStore.inspect_summary(session_id: str, *, checkpoint_root_guard: CheckpointRootFieldGuard | None=None) -> SessionInspectionSummaryReturn one exact, content-free diagnostic summary.
The default implementation deliberately composes the public paginated query contracts so out-of-tree stores gain the same semantics without a backend-specific schema dependency. Implementations may replace it with an equivalent bounded native aggregate.
list_sessions (method)
Section titled “list_sessions (method)”async InMemorySessionStore.list_sessions(query: SessionQuery | None=None) -> SessionListResultquery_session_topology (method)
Section titled “query_session_topology (method)”async InMemorySessionStore.query_session_topology(query: SessionTopologyQuery) -> SessionTopologyStoreResultquery_session_lineage (method)
Section titled “query_session_lineage (method)”async InMemorySessionStore.query_session_lineage(query: SessionLineageQuery) -> SessionLineageResultquery_child_session_lifecycle (method)
Section titled “query_child_session_lifecycle (method)”async InMemorySessionStore.query_child_session_lifecycle(query: ChildSessionLifecycleQuery) -> ChildSessionLifecyclePageaggregate_operational_snapshot (method)
Section titled “aggregate_operational_snapshot (method)”async InMemorySessionStore.aggregate_operational_snapshot(filters: SessionAggregateFilter | None=None) -> SessionOperationalSnapshotaggregate_usage (method)
Section titled “aggregate_usage (method)”async InMemorySessionStore.aggregate_usage(query: UsageRollupQuery) -> UsageRollupStoreResultlist_sessions_with_pending_interruption_cascade (method)
Section titled “list_sessions_with_pending_interruption_cascade (method)”async InMemorySessionStore.list_sessions_with_pending_interruption_cascade(query: SessionQuery | None=None) -> SessionListResultlist_queued_dispatch_terminal_receipts (method)
Section titled “list_queued_dispatch_terminal_receipts (method)”async InMemorySessionStore.list_queued_dispatch_terminal_receipts(query: QueuedDispatchTerminalReceiptQuery | None=None) -> list[QueuedDispatchTerminalReceipt]query_pending_actions (method)
Section titled “query_pending_actions (method)”async InMemorySessionStore.query_pending_actions(query: PendingActionQuery | None=None, *, checkpoint_root_guard: CheckpointRootFieldGuard | None=None) -> PendingActionListResultvalidate_session_closure_admission (method)
Section titled “validate_session_closure_admission (method)”async InMemorySessionStore.validate_session_closure_admission(session_id: str) -> Noneload_session_closure_records (method)
Section titled “load_session_closure_records (method)”async InMemorySessionStore.load_session_closure_records(session_id: str, *, max_records: int, max_bytes: int) -> dict[str, Any]delete_session (method)
Section titled “delete_session (method)”async InMemorySessionStore.delete_session(session_id: str, *, closure_receipt: dict[str, Any] | None=None, _access_bounds: _SessionAccessBounds | None=None) -> Nonedetach_session_children (method)
Section titled “detach_session_children (method)”async InMemorySessionStore.detach_session_children(parent_session_id: str, child_session_ids: tuple[str, ...], *, closure_receipt: dict[str, Any]) -> tuple[dict[str, Any], ...]load_session_closure_tombstones (method)
Section titled “load_session_closure_tombstones (method)”async InMemorySessionStore.load_session_closure_tombstones(root_session_id: str, plan_id: str) -> tuple[dict[str, Any], ...]load_session_closure_receipt (method)
Section titled “load_session_closure_receipt (method)”async InMemorySessionStore.load_session_closure_receipt(session_id: str, plan_id: str) -> dict[str, Any] | Noneload_session_closure_progress (method)
Section titled “load_session_closure_progress (method)”async InMemorySessionStore.load_session_closure_progress(session_id: str, plan_id: str)save_session_closure_progress (method)
Section titled “save_session_closure_progress (method)”async InMemorySessionStore.save_session_closure_progress(progress: dict[str, Any]) -> Noneclaim_session_closure_progress (method)
Section titled “claim_session_closure_progress (method)”async InMemorySessionStore.claim_session_closure_progress(progress: dict[str, Any]) -> Noneupdate_labels (method)
Section titled “update_labels (method)”async InMemorySessionStore.update_labels(session_id: str, labels: dict[str, str], *, _access_bounds: _SessionAccessBounds | None=None) -> Sessionupdate_metadata (method)
Section titled “update_metadata (method)”async InMemorySessionStore.update_metadata(session_id: str, metadata: dict[str, Any], *, _access_bounds: _SessionAccessBounds | None=None) -> Sessionappend_transcript_messages (method)
Section titled “append_transcript_messages (method)”async InMemorySessionStore.append_transcript_messages(session_id: str, messages: list[Message], *, interaction_id: InteractionAttribution=INHERIT_INTERACTION) -> Nonereplace_initial_transcript_messages (method)
Section titled “replace_initial_transcript_messages (method)”async InMemorySessionStore.replace_initial_transcript_messages(session_id: str, expected_messages: list[Message], replacement_messages: list[Message], *, interaction_id: InteractionAttribution=INHERIT_INTERACTION, checkpoint_transform: CheckpointTransform | None=None, runtime_suffix_count: int=0) -> Noneload_deferred_interaction_input (method)
Section titled “load_deferred_interaction_input (method)”async InMemorySessionStore.load_deferred_interaction_input(session_id: str) -> DeferredInteractionInput | Nonematerialize_deferred_interaction_input (method)
Section titled “materialize_deferred_interaction_input (method)”async InMemorySessionStore.materialize_deferred_interaction_input(session_id: str, *, interaction_id: InteractionAttribution=INHERIT_INTERACTION) -> boolappend_transcript_messages_and_transform_checkpoint (method)
Section titled “append_transcript_messages_and_transform_checkpoint (method)”async InMemorySessionStore.append_transcript_messages_and_transform_checkpoint(session_id: str, messages: list[Message], checkpoint_transform: CheckpointTransform, *, interaction_id: InteractionAttribution=INHERIT_INTERACTION) -> Noneload_transcript (method)
Section titled “load_transcript (method)”async InMemorySessionStore.load_transcript(session_id: str) -> list[Message]load_transcript_snapshot (method)
Section titled “load_transcript_snapshot (method)”async InMemorySessionStore.load_transcript_snapshot(session_id: str) -> TranscriptSnapshotload_transcript_cursor (method)
Section titled “load_transcript_cursor (method)”async InMemorySessionStore.load_transcript_cursor(session_id: str) -> intload_transcript_window (method)
Section titled “load_transcript_window (method)”async InMemorySessionStore.load_transcript_window(session_id: str, *, start_index: int, limit: int) -> TranscriptSnapshotLoad a bounded absolute-index window and its permanent append cursor.
start_index is inclusive. If its message was removed, return the
first surviving records at or after it; at or beyond the append cursor,
return no records. The returned cursor is the full logical extent, not
the end of this window. Continue from the last returned index plus one.
An empty window does not prove that earlier payloads never existed.
Stores may override this method to avoid loading the complete retained
transcript. The default keeps custom stores correct through their atomic
load_transcript_snapshot implementation.
load_latest_transcript_message (method)
Section titled “load_latest_transcript_message (method)”async InMemorySessionStore.load_latest_transcript_message(session_id: str, *, role: MessageRole) -> TranscriptRecord | Noneload_latest_transcript_text (method)
Section titled “load_latest_transcript_text (method)”async InMemorySessionStore.load_latest_transcript_text(session_id: str, *, role: MessageRole, max_chars: int) -> tuple[str, bool] | Nonequery_transcript (method)
Section titled “query_transcript (method)”async InMemorySessionStore.query_transcript(query: TranscriptQuery) -> TranscriptPagesearch_transcript (method)
Section titled “search_transcript (method)”async InMemorySessionStore.search_transcript(query: TranscriptSearchQuery) -> TranscriptSearchResultcreate_recall_receipt (method)
Section titled “create_recall_receipt (method)”async InMemorySessionStore.create_recall_receipt(receipt: RecallReceipt) -> RecallReceiptload_recall_receipt (method)
Section titled “load_recall_receipt (method)”async InMemorySessionStore.load_recall_receipt(session_id: str, receipt_id: str) -> RecallReceipt | Nonelist_recall_receipts (method)
Section titled “list_recall_receipts (method)”async InMemorySessionStore.list_recall_receipts(query: RecallEvidenceQuery) -> RecallReceiptPagecreate_context_exposure (method)
Section titled “create_context_exposure (method)”async InMemorySessionStore.create_context_exposure(exposure: ContextExposure, item_exposures: tuple[RecallItemExposure, ...]=()) -> ContextExposureload_context_exposure (method)
Section titled “load_context_exposure (method)”async InMemorySessionStore.load_context_exposure(session_id: str, exposure_id: str) -> ContextExposure | Noneload_recall_item_exposures (method)
Section titled “load_recall_item_exposures (method)”async InMemorySessionStore.load_recall_item_exposures(session_id: str, exposure_id: str) -> tuple[RecallItemExposure, ...]list_context_exposures (method)
Section titled “list_context_exposures (method)”async InMemorySessionStore.list_context_exposures(query: RecallEvidenceQuery) -> ContextExposurePagetransition_context_exposure (method)
Section titled “transition_context_exposure (method)”async InMemorySessionStore.transition_context_exposure(session_id: str, exposure_id: str, request: ContextExposureTransitionRequest) -> ContextExposurecheckpoint (method)
Section titled “checkpoint (method)”async InMemorySessionStore.checkpoint(session_id: str, state: dict[str, Any]) -> Nonetransform_checkpoint (method)
Section titled “transform_checkpoint (method)”async InMemorySessionStore.transform_checkpoint(session_id: str, checkpoint_transform: CheckpointTransform) -> Nonetransform_checkpoint_with_store_time (method)
Section titled “transform_checkpoint_with_store_time (method)”async InMemorySessionStore.transform_checkpoint_with_store_time(session_id: str, checkpoint_transform: StoreTimeCheckpointTransform) -> Noneload_checkpoint (method)
Section titled “load_checkpoint (method)”async InMemorySessionStore.load_checkpoint(session_id: str) -> dict[str, Any] | Noneload_interruption_cascade_marker (method)
Section titled “load_interruption_cascade_marker (method)”async InMemorySessionStore.load_interruption_cascade_marker(session_id: str, *, checkpoint_root_guard: CheckpointRootFieldGuard | None=None) -> dict[str, Any] | Noneinit (method)
Section titled “init (method)”InMemorySessionStore.__init__(*, public_authority_alias_codec: PublicAuthorityAliasCodec | None=None, ownership_clock: Callable[[], datetime] | None=None) -> None