openai4s/store.py

_strip_sql_literals · function · L829-L831 — def _strip_sql_literals(sql: str) -> str
_now_ms · function · L849-L850 — def _now_ms() -> int
_sql_quote · function · L861-L863 — def _sql_quote(value: str) -> str
_sql_cte_tokens · function · L905-L961 — def _sql_cte_tokens(sql: str) -> list[tuple[str, str]]
_after_sql_parentheses · function · L964-L979 — def _after_sql_parentheses(tokens: list[tuple[str, str]], index: int) -> int | None
_is_sql_word · function · L982-L983 — def _is_sql_word(token: tuple[str, str], word: str) -> bool
_cte_shadow_name · function · L986-L1030 — def _cte_shadow_name(sql: str) -> str | None
_QueryAuthorizer · class · L1104-L1192 — class _QueryAuthorizer
init · method · L1123-L1142 — def init( self, view_only: frozenset[str] | None = None, *, published_views: frozenset[str] = frozenset(), ) -> None
_deny · method · L1144-L1147 — def _deny(self, what: str) -> int
call · method · L1149-L1192 — def call( self, action: int, arg1: str | None, arg2: str | None, dbname: str | None, source: str | None, ) -> int: # Anything that is not a read or a plain SELECT is refused outright. # This runs on the daemon's read-write connection, so it is the only # thing standing between agent SQL and an UPDATE -- and it refuses by # action code rather than by keyword, which is what makes a statement # like SELECT 1; DROP TABLE artifacts or a temp-table write, an ATTACH, # or a function-driven side effect unreachable rather than merely unspelled.
_allow_everything · function · L1215-L1216 — def _allow_everything(*_event: object) -> int
_clear_authorizer · function · L1219-L1221 — def _clear_authorizer(conn: sqlite3.Connection) -> None
Store · class · L1224-L5907 — class Store
init · method · L1227-L1484 — def init(self, db_path: Path)
_migrate · method · L1556-L1657 — def _migrate(self) -> None
_apply_datapro_content_index · method · L1659-L1662 — def _apply_datapro_content_index(self, conn: sqlite3.Connection) -> None
_apply_team_users · method · L1664-L1673 — def _apply_team_users(self, conn: sqlite3.Connection) -> None
_apply_session_owners · method · L1675-L1682 — def _apply_session_owners(self, conn: sqlite3.Connection) -> None
_apply_orchestration_workloads · method · L1684-L1692 — def _apply_orchestration_workloads(self, conn: sqlite3.Connection) -> None
_apply_orchestration_leases · method · L1694-L1702 — def _apply_orchestration_leases(self, conn: sqlite3.Connection) -> None
_apply_user_llm_keys · method · L1704-L1712 — def _apply_user_llm_keys(self, conn: sqlite3.Connection) -> None
_apply_artifact_delivery · method · L1714-L1724 — def _apply_artifact_delivery(self, conn: sqlite3.Connection) -> None
_apply_auto_mode_state · method · L1726-L1735 — def _apply_auto_mode_state(self, conn: sqlite3.Connection) -> None
_apply_auto_mode_budget_admission · method · L1737-L1746 — def _apply_auto_mode_budget_admission(self, conn: sqlite3.Connection) -> None
_apply_annotation_locators · method · L1748-L1761 — def _apply_annotation_locators(self, conn: sqlite3.Connection) -> None
_apply_compute_job_input_versions · method · L1763-L1777 — def _apply_compute_job_input_versions(self, conn: sqlite3.Connection) -> None
_apply_delegation_generation_and_task_status · method · L1779-L1810 — def _apply_delegation_generation_and_task_status( self, conn: sqlite3.Connection ) -> None
_apply_delegation_requests_and_attempts · method · L1812-L1820 — def _apply_delegation_requests_and_attempts(self, conn: sqlite3.Connection) -> None
_apply_model_capability_receipts · method · L1822-L1829 — def _apply_model_capability_receipts(self, conn: sqlite3.Connection) -> None
_apply_artifact_browse_index · method · L1831-L1843 — def _apply_artifact_browse_index(self, conn: sqlite3.Connection) -> None
_apply_team_governance · method · L1845-L1851 — def _apply_team_governance(self, conn: sqlite3.Connection) -> None
_apply_datapro_content_index_repair · method · L1853-L1863 — def _apply_datapro_content_index_repair(self, conn: sqlite3.Connection) -> None
_apply_annotation_admission_ledger · method · L1865-L1925 — def _apply_annotation_admission_ledger(self, conn: sqlite3.Connection) -> None
_apply_annotation_reservation · method · L1927-L1955 — def _apply_annotation_reservation(self, conn: sqlite3.Connection) -> None
_apply_memory_updated_at · method · L1957-L1981 — def _apply_memory_updated_at(self, conn: sqlite3.Connection) -> None
_apply_annotation_version_binding · method · L1983-L2004 — def _apply_annotation_version_binding(self, conn: sqlite3.Connection) -> None
_apply_compute_job_idem_owner · method · L2006-L2038 — def _apply_compute_job_idem_owner(self, conn: sqlite3.Connection) -> None
_apply_compute_job_states · method · L2040-L2080 — def _apply_compute_job_states(self, conn: sqlite3.Connection) -> None
_apply_artifact_source · method · L2082-L2108 — def _apply_artifact_source(self, conn: sqlite3.Connection) -> None
_apply_artifact_env_identity · method · L2110-L2138 — def _apply_artifact_env_identity(self, conn: sqlite3.Connection) -> None
_apply_compute_job_pgid · method · L2140-L2169 — def _apply_compute_job_pgid(self, conn: sqlite3.Connection) -> None
_apply_frame_model_binding · method · L2171-L2204 — def _apply_frame_model_binding(self, conn: sqlite3.Connection) -> None
_apply_compute_job_owner · method · L2206-L2232 — def _apply_compute_job_owner(self, conn: sqlite3.Connection) -> None
_apply_env_snapshot_generation · method · L2234-L2315 — def _apply_env_snapshot_generation(self, conn: sqlite3.Connection) -> None
_apply_env_snapshot_provenance · method · L2317-L2344 — def _apply_env_snapshot_provenance(self, conn: sqlite3.Connection) -> None
_apply_compute_job_manifest · method · L2346-L2369 — def _apply_compute_job_manifest(self, conn: sqlite3.Connection) -> None
_apply_legacy_baseline · method · L2371-L2479 — def _apply_legacy_baseline(self, conn: sqlite3.Connection) -> None
_apply_pragmas · method · L2481-L2510 — def _apply_pragmas(self) -> None
team · method · L2514-L2516 — def team(self) -> TeamRepository
governance · method · L2519-L2521 — def governance(self) -> GovernanceRepository
workloads · method · L2524-L2527 — def workloads(self) -> WorkloadRepository
user_keys · method · L2530-L2532 — def user_keys(self) -> UserKeyRepository
model_capability_receipts · method · L2535-L2537 — def model_capability_receipts(self) -> ModelCapabilityReceiptRepository
leases · method · L2540-L2542 — def leases(self) -> LeaseRepository
secrets · method · L2545-L2559 — def secrets(self)
get_secret_setting · method · L2561-L2577 — def get_secret_setting(self, key: str, *, scope: str | None = None) -> str
set_secret_setting · method · L2579-L2614 — def set_secret_setting(self, key: str, value: str, *, scope: str) -> str
schema_state · method · L2617-L2632 — def schema_state(self) -> dict
_exec · method · L2635-L2638 — def _exec(self, sql: str, params: tuple = ()) -> None
close · method · L2640-L2659 — def close(self) -> None
_load_capability_receipt_overlays · method · L2661-L2681 — def _load_capability_receipt_overlays(self) -> None
new_frame · method · L2684-L2703 — def new_frame( self, *, parent_id: str | None = None, project_id: str = "default", kind: str = "turn", name: str | None = None, model: str | None = None, depth: int = 0, status: str = "processing", ) -> str
resolve_frame_scope · method · L2705-L2714 — def resolve_frame_scope( self, frame_id: str | None, *, fallback_project: str = "default", ) -> dict
unpin_model · method · L2716-L2717 — def unpin_model(self, frame_id: str) -> None
release_model_binding · method · L2719-L2720 — def release_model_binding(self, profile_id: str) -> int
update_frame · method · L2722-L2723 — def update_frame(self, frame_id: str, **fields: Any) -> None
add_frame_tokens · method · L2725-L2738 — def add_frame_tokens( self, frame_id: str, *, input_tokens: int = 0, output_tokens: int = 0, cost_usd: float = 0.0, ) -> None
create_project · method · L2741-L2756 — def create_project( self, *, name: str, description: str = "", context: str = "", project_id: str | None = None, is_example: bool = False, ) -> dict
create_quarantined_import_session · method · L2758-L2767 — def create_quarantined_import_session( self, *, project_id: str, quarantine_value: str, ) -> dict[str, Any]
get_project · method · L2769-L2770 — def get_project(self, project_id: str) -> dict | None
update_project · method · L2772-L2773 — def update_project(self, project_id: str, **fields: Any) -> None
delete_project · method · L2775-L2776 — def delete_project(self, project_id: str) -> dict
project_session_ids · method · L2778-L2779 — def project_session_ids(self, project_id: str) -> list[str]
list_projects · method · L2781-L2796 — def list_projects( self, *, q: str | None = None, limit: int | None = None, offset: int | None = None, before: tuple[int | None, str] | None = None, visible_to_user_id: str | None = None, ) -> list[dict]
count_projects · method · L2798-L2801 — def count_projects( self, *, q: str | None = None, visible_to_user_id: str | None = None ) -> int
add_message · method · L2804-L2823 — def add_message( self, *, root_frame_id: str, branch_id: str | None = None, role: str, content: str, frame_id: str | None = None, metadata: dict | None = None, created_at: int | None = None, ) -> dict
update_message_metadata · method · L2825-L2826 — def update_message_metadata(self, message_id: str, patch: dict) -> dict | None
promote_candidate_message · method · L2828-L2847 — def promote_candidate_message( self, *, message_id: str, root_frame_id: str, branch_id: str, frame_id: str | None, expected_content: str, content: str, metadata: Mapping[str, Any], ) -> dict
commit_completion_delivery · method · L2849-L2874 — def commit_completion_delivery( self, *, idempotency_key: str, root_frame_id: str, branch_id: str | None, frame_id: str | None, content: str, manifest: Mapping[str, Any], message_metadata: Mapping[str, Any] | None = None, expected_manifest_sha256: str | None = None, created_at: int | None = None, snapshot_verifier: Callable[[Mapping[str, Any]], object] | None = None, ) -> dict[str, Any]
promote_candidate_delivery · method · L2876-L2897 — def promote_candidate_delivery( self, *, delivery_id: str, message_id: str, root_frame_id: str, branch_id: str | None, frame_id: str | None, expected_content: str, content: str, message_metadata: Mapping[str, Any], ) -> dict[str, Any]
mark_completion_delivery_published · method · L2899-L2908 — def mark_completion_delivery_published( self, delivery_id: str, *, published_at: int | None = None, ) -> dict[str, Any]
get_completion_delivery · method · L2910-L2911 — def get_completion_delivery(self, delivery_id: str) -> dict[str, Any] | None
committed_completion_deliveries · method · L2913-L2924 — def committed_completion_deliveries( self, *, root_frame_id: str | None = None, branch_id: str | None = None, limit: int = 1000, ) -> list[dict[str, Any]]
completion_deliveries_for_session · method · L2926-L2935 — def completion_deliveries_for_session( self, root_frame_id: str, *, limit: int = 10_000, ) -> list[dict[str, Any]]
bind_imported_completion_delivery · method · L2937-L2941 — def bind_imported_completion_delivery( self, **fields: Any, ) -> dict[str, Any]
list_messages · method · L2943-L2964 — def list_messages( self, root_frame_id: str, *, branch_id: str | None = None, start: int = 0, limit: int | None = 300, before_seq: int | None = None, newest_first: bool = False, ) -> list[dict]
list_message_boundaries · method · L2966-L2983 — def list_message_boundaries( self, root_frame_id: str, *, branch_id: str | None = None, start: int = 0, limit: int | None = 300, ) -> list[dict]
list_branch_messages · method · L2985-L3039 — def list_branch_messages( self, root_frame_id: str, *, branch_id: str | None = None, start: int = 0, limit: int | None = 300, before_seq: int | None = None, newest_first: bool = False, boundaries: bool = False, ) -> list[dict]
list_branch_message_boundaries · method · L3041-L3059 — def list_branch_message_boundaries( self, root_frame_id: str, *, branch_id: str | None = None, start: int = 0, limit: int | None = 300, before_seq: int | None = None, newest_first: bool = False, ) -> list[dict]
message_count · method · L3061-L3062 — def message_count(self, root_frame_id: str) -> int
has_message_history · method · L3064-L3065 — def has_message_history(self) -> bool
has_execution_history · method · L3067-L3068 — def has_execution_history(self) -> bool
cell_count · method · L3070-L3071 — def cell_count(self, root_frame_id: str) -> int
latest_state_revision · method · L3073-L3074 — def latest_state_revision(self, root_frame_id: str) -> int
add_step · method · L3079-L3096 — def add_step( self, *, step_id: str, frame_id: str, kind: str, title: str | None = None, input: dict | None = None, status: str = "running", ) -> dict
update_step · method · L3098-L3113 — def update_step( self, step_id: str, *, status: str | None = None, output: dict | None = None, title: str | None = None, summary: str | None = None, ) -> None
list_steps · method · L3115-L3118 — def list_steps( self, frame_id: str, *, start: int = 0, limit: int = 800 ) -> list[dict]
step_count · method · L3120-L3121 — def step_count(self, frame_id: str) -> int
browse_frames · method · L3124-L3141 — def browse_frames( self, *, project_id: str | None = "default", status: str | None = None, roots_only: bool = True, limit: int = 50, before: tuple[int, str] | None = None, visible_to_user_id: str | None = None, ) -> list[dict]
frame_detail · method · L3143-L3156 — def frame_detail( self, frame_id: str, *, page: int = 0, page_size: int = 50, visible_to_user_id: str | None = None, ) -> dict | None
search_frames · method · L3158-L3171 — def search_frames( self, pattern: str, *, project_id: str | None = "default", limit: int = 50, visible_to_user_id: str | None = None, ) -> list[dict]
log_cell · method · L3174-L3215 — def log_cell( self, *, frame_id: str | None, code: str, result: dict, origin: str = "agent", cell_seq: int | None = None, project_id: str = "default", root_frame_id: str | None = None, cell_index: int | None = None, state_revision: int | None = None, kernel_id: str = "python", language: str = "python", visibility: str | None = None, pin: bool = False, replay_policy: str | None = None, figures: list | None = None, files_read: list | None = None, files_written: list | None = None, generation_id: str | None = None, ) -> str
list_cells · method · L3217-L3220 — def list_cells( self, root_frame_id: str, *, branch_id: str | None = None ) -> list[dict]
list_cell_outputs · method · L3222-L3223 — def list_cell_outputs(self, root_frame_id: str) -> list[dict]
cell_detail · method · L3225-L3226 — def cell_detail(self, producing_cell_id: str) -> dict | None
append_action_group · method · L3229-L3262 — def append_action_group( self, *, root_frame_id: str, turn_id: str, kind: str, branch_id: str | None = None, ordinal: int | None = None, provider: str | None = None, model: str | None = None, wire_state: Any = None, assistant_content: str | None = None, assistant_message: Any = None, usage: dict[str, Any] | None = None, cost_usd: float | None = None, group_id: str | None = None, created_at: int | None = None, ) -> dict
append_action_event · method · L3264-L3295 — def append_action_event( self, *, group_id: str, type: str, sequence: int | None = None, action_id: str | None = None, tool_call_id: str | None = None, wire_id: str | None = None, canonical_arguments: Any = None, raw_arguments: Any = None, result: Any = None, side_effect_class: str | None = None, resource_keys: list[str] | tuple[str, ...] | None = None, event_id: str | None = None, created_at: int | None = None, ) -> dict
append_tool_action_group · method · L3297-L3330 — def append_tool_action_group( self, *, root_frame_id: str, turn_id: str, events: list[dict[str, Any]], branch_id: str | None = None, ordinal: int | None = None, provider: str | None = None, model: str | None = None, wire_state: Any = None, assistant_content: str | None = None, assistant_message: Any = None, usage: dict[str, Any] | None = None, cost_usd: float | None = None, group_id: str | None = None, created_at: int | None = None, ) -> dict
append_action_group_with_events · method · L3332-L3353 — def append_action_group_with_events( self, *, root_frame_id: str, branch_id: str, turn_id: str, kind: str, events: list[dict[str, Any]], group_id: str, admission_operation: str, ) -> dict
get_action_group · method · L3355-L3358 — def get_action_group( self, group_id: str, *, include_events: bool = True ) -> dict | None
latest_action_group_ordinal · method · L3360-L3369 — def latest_action_group_ordinal( self, root_frame_id: str, *, branch_id: str | None = None, kind: str | None = None, ) -> int | None
list_action_groups · method · L3371-L3388 — def list_action_groups( self, root_frame_id: str, *, branch_id: str | None = None, turn_id: str | None = None, after_ordinal: int | None = None, limit: int | None = None, include_events: bool = True, ) -> list[dict]
list_action_events · method · L3390-L3391 — def list_action_events(self, group_id: str) -> list[dict]
allocate_execution_attempt · method · L3393-L3416 — def allocate_execution_attempt( self, *, group_id: str, producing_cell_id: str, state_revision: int | None = None, generation_id: str | None = None, owner_instance_id: str | None = None, replayed_from_cell_id: str | None = None, attempt_ordinal: int | None = None, attempt_id: str | None = None, allocated_at: int | None = None, ) -> dict
mark_execution_attempt_started · method · L3418-L3421 — def mark_execution_attempt_started( self, attempt_id: str, *, started_at: int | None = None ) -> dict
bind_execution_attempt_generation · method · L3423-L3426 — def bind_execution_attempt_generation( self, attempt_id: str, generation_id: str ) -> dict
abandon_incomplete_execution_attempts · method · L3428-L3437 — def abandon_incomplete_execution_attempts( self, *, owner_instance_id: str, finished_at: int | None = None, ) -> int
mark_execution_attempt_response · method · L3439-L3442 — def mark_execution_attempt_response( self, attempt_id: str, *, response_at: int | None = None ) -> dict
mark_execution_attempt_capture · method · L3444-L3447 — def mark_execution_attempt_capture( self, attempt_id: str, *, capture_at: int | None = None ) -> dict
finish_execution_attempt · method · L3449-L3462 — def finish_execution_attempt( self, attempt_id: str, *, terminal_state: str, error: Any = None, finished_at: int | None = None, ) -> dict
get_execution_attempt · method · L3464-L3465 — def get_execution_attempt(self, attempt_id: str) -> dict | None
list_execution_attempts · method · L3467-L3482 — def list_execution_attempts( self, *, group_id: str | None = None, producing_cell_id: str | None = None, root_frame_id: str | None = None, branch_id: str | None = None, turn_id: str | None = None, ) -> list[dict]
create_kernel_generation · method · L3485-L3486 — def create_kernel_generation(self, **fields: Any) -> dict
touch_kernel_generation · method · L3488-L3489 — def touch_kernel_generation(self, generation_id: str, **fields: Any) -> dict
compare_and_swap_kernel_bootstrap · method · L3491-L3504 — def compare_and_swap_kernel_bootstrap( self, generation_id: str, *, expected_manifest_id: str | None, bootstrap: Any, at: int | None = None, ) -> dict | None
finish_kernel_generation · method · L3506-L3519 — def finish_kernel_generation( self, generation_id: str, *, state: str, reason: str, ended_at: int | None = None, ) -> dict
abandon_live_kernel_generations · method · L3521-L3532 — def abandon_live_kernel_generations( self, *, owner_instance_id: str, reason: str = "daemon_restart", ended_at: int | None = None, ) -> int
get_kernel_generation · method · L3534-L3535 — def get_kernel_generation(self, generation_id: str) -> dict | None
latest_kernel_generation · method · L3537-L3548 — def latest_kernel_generation( self, root_frame_id: str, language: str, *, branch_id: str | None = None, ) -> dict | None
list_kernel_generations · method · L3550-L3561 — def list_kernel_generations( self, root_frame_id: str, *, language: str | None = None, branch_id: str | None = None, ) -> list[dict]
reconcile_orphaned_auto_mode_candidates · method · L3564-L3567 — def reconcile_orphaned_auto_mode_candidates( self, *, now: int ) -> list[dict[str, Any]]
reconcile_orphaned_auto_mode_runs · method · L3569-L3574 — def reconcile_orphaned_auto_mode_runs( self, *, owner_instance_id: str, now: int ) -> list[dict]
get_auto_mode_selection · method · L3576-L3577 — def get_auto_mode_selection(self, scope_kind: str, scope_id: str) -> dict | None
set_auto_mode_selection · method · L3579-L3591 — def set_auto_mode_selection( self, scope_kind: str, scope_id: str, values: dict, expected_revision: int, ) -> dict
start_auto_mode_run · method · L3593-L3594 — def start_auto_mode_run(self, **fields: Any) -> dict
record_auto_mode_candidate · method · L3596-L3597 — def record_auto_mode_candidate(self, run_id: str, **fields: Any) -> dict
start_auto_mode_review · method · L3599-L3600 — def start_auto_mode_review(self, run_id: str, **fields: Any) -> dict
complete_auto_mode_review · method · L3602-L3603 — def complete_auto_mode_review(self, review_run_id: str, **fields: Any) -> dict
start_auto_mode_repair · method · L3605-L3606 — def start_auto_mode_repair(self, run_id: str, **fields: Any) -> dict
complete_auto_mode_repair · method · L3608-L3609 — def complete_auto_mode_repair(self, repair_run_id: str, **fields: Any) -> dict
bind_auto_mode_repair_execution_group · method · L3611-L3614 — def bind_auto_mode_repair_execution_group( self, repair_run_id: str, **fields: Any ) -> dict
start_permission_review_assessment · method · L3616-L3617 — def start_permission_review_assessment(self, run_id: str, **fields: Any) -> dict
complete_permission_review_assessment · method · L3619-L3622 — def complete_permission_review_assessment( self, assessment_id: str, **fields: Any ) -> dict
terminate_auto_mode_run · method · L3624-L3625 — def terminate_auto_mode_run(self, run_id: str, **fields: Any) -> dict
auto_mode_event_cursor · method · L3627-L3630 — def auto_mode_event_cursor( self, root_frame_id: str, branch_id: str | None = None ) -> int
list_auto_mode_events · method · L3632-L3647 — def list_auto_mode_events( self, root_frame_id: str, *, branch_id: str | None = None, after_cursor: int | None = None, upto_cursor: int | None = None, limit: int = 100_000, ) -> list[dict]
project_auto_mode_run · method · L3649-L3659 — def project_auto_mode_run( self, root_frame_id: str, branch_id: str, upto_event_cursor: int | None = None, ) -> dict
list_auto_mode_audits · method · L3661-L3676 — def list_auto_mode_audits( self, root_frame_id: str, branch_id: str, *, subject_kind: str | None = None, before: str | None = None, limit: int = 100, ) -> list[dict]
export_auto_mode_projection · method · L3678-L3689 — def export_auto_mode_projection( self, root_frame_id: str, *, branch_id: str | None = None, upto_event_cursor: int | None = None, ) -> dict
import_quarantined_auto_mode_projection · method · L3691-L3694 — def import_quarantined_auto_mode_projection( self, source: dict, **context: Any ) -> dict
ensure_auto_mode_budget_state · method · L3696-L3697 — def ensure_auto_mode_budget_state(self, run_id: str, **fields: Any) -> dict | None
get_auto_mode_budget_state · method · L3699-L3700 — def get_auto_mode_budget_state(self, run_id: str) -> dict | None
list_auto_mode_budget_reservations · method · L3702-L3703 — def list_auto_mode_budget_reservations(self, run_id: str) -> list[dict]
reserve_auto_mode_budget · method · L3705-L3706 — def reserve_auto_mode_budget(self, **fields: Any) -> dict
commit_auto_mode_budget · method · L3708-L3709 — def commit_auto_mode_budget(self, admission_id: str, **fields: Any) -> dict
release_auto_mode_budget · method · L3711-L3712 — def release_auto_mode_budget(self, admission_id: str, **fields: Any) -> dict
mark_auto_mode_budget_unknown · method · L3714-L3715 — def mark_auto_mode_budget_unknown(self, admission_id: str) -> dict
reconcile_auto_mode_budget · method · L3717-L3718 — def reconcile_auto_mode_budget(self, admission_id: str, **fields: Any) -> dict
record_auto_mode_budget_delta · method · L3720-L3721 — def record_auto_mode_budget_delta(self, run_id: str, **fields: Any) -> dict
freeze_auto_mode_budget_initial_tokens · method · L3723-L3726 — def freeze_auto_mode_budget_initial_tokens( self, run_id: str, tokens: int, **fields: Any ) -> dict
trip_auto_mode_budget_circuit · method · L3728-L3729 — def trip_auto_mode_budget_circuit(self, run_id: str, **fields: Any) -> dict
project_auto_mode_budget · method · L3731-L3732 — def project_auto_mode_budget(self, run_id: str) -> dict | None
ensure_session_branch · method · L3735-L3736 — def ensure_session_branch(self, **fields: Any) -> dict
create_session_checkpoint · method · L3738-L3739 — def create_session_checkpoint(self, **fields: Any) -> dict
get_checkpoint_state_snapshot · method · L3741-L3750 — def get_checkpoint_state_snapshot( self, checkpoint_id: str, *, include_state: bool = False, ) -> dict | None
list_checkpoint_state_snapshots · method · L3752-L3763 — def list_checkpoint_state_snapshots( self, root_frame_id: str, *, branch_id: str | None = None, limit: int = 100, ) -> list[dict]
import_quarantined_checkpoint_state · method · L3765-L3784 — def import_quarantined_checkpoint_state( self, source: dict, *, checkpoint_id: str, root_frame_id: str, branch_id: str, project_id: str, artifact_id_map: dict[str, str] | None = None, source_checkpoint_id: str | None = None, ) -> dict
validate_checkpoint_state_import · method · L3786-L3795 — def validate_checkpoint_state_import( self, source: dict, *, include_state: bool = False, ) -> dict
restore_checkpoint_state_snapshot · method · L3797-L3815 — def restore_checkpoint_state_snapshot( self, *, checkpoint_id: str, root_frame_id: str, project_id: str, ) -> dict
fork_session_branch · method · L3817-L3818 — def fork_session_branch(self, **fields: Any) -> dict
get_session_checkpoint · method · L3820-L3821 — def get_session_checkpoint(self, checkpoint_id: str) -> dict | None
get_session_checkpoint_for_source · method · L3823-L3834 — def get_session_checkpoint_for_source( self, root_frame_id: str, *, source_kind: str, source_id: str, ) -> dict | None
session_checkpoint_source_map · method · L3836-L3842 — def session_checkpoint_source_map( self, root_frame_id: str, *, source_kind: str ) -> dict[str, str]
list_session_checkpoints · method · L3844-L3855 — def list_session_checkpoints( self, root_frame_id: str, *, branch_id: str | None = None, limit: int = 100, ) -> list[dict]
retained_workspace_tree_ids · method · L3857-L3858 — def retained_workspace_tree_ids(self) -> tuple[str, ...]
get_session_branch · method · L3860-L3861 — def get_session_branch(self, branch_id: str) -> dict | None
list_session_branches · method · L3863-L3864 — def list_session_branches(self, root_frame_id: str) -> list[dict]
ensure_active_session_branch · method · L3866-L3867 — def ensure_active_session_branch(self, root_frame_id: str) -> str
active_session_branch · method · L3869-L3870 — def active_session_branch(self, root_frame_id: str) -> str
session_export_guard · method · L3872-L3878 — def session_export_guard(self, root_frame_id: str) -> dict
activate_session_branch_checkpoint · method · L3880-L3881 — def activate_session_branch_checkpoint(self, **fields: Any) -> dict
record_snapshot_operation · method · L3883-L3884 — def record_snapshot_operation(self, **fields: Any) -> dict
get_snapshot_operation · method · L3886-L3887 — def get_snapshot_operation(self, operation_id: str) -> dict | None
list_snapshot_operations · method · L3889-L3904 — def list_snapshot_operations( self, root_frame_id: str, *, branch_id: str | None = None, kind: str | None = None, status: str | None = None, limit: int = 100, ) -> list[dict]
append_recovery_event · method · L3907-L3908 — def append_recovery_event(self, **fields: Any) -> dict
list_recovery_events · method · L3910-L3925 — def list_recovery_events( self, *, recovery_id: str | None = None, root_frame_id: str | None = None, branch_id: str | None = None, limit: int = 1000, newest: bool = False, ) -> list[dict]
restore_delegation_tree · method · L3928-L3929 — def restore_delegation_tree(self, **fields: Any) -> dict
reserve_delegation_children · method · L3931-L3932 — def reserve_delegation_children(self, **fields: Any) -> dict
release_delegation_budget · method · L3934-L3935 — def release_delegation_budget(self, **fields: Any) -> dict
persist_delegation_child · method · L3937-L3938 — def persist_delegation_child(self, **fields: Any) -> dict | None
continue_delegation_request · method · L3940-L3941 — def continue_delegation_request(self, **fields: Any) -> dict
delegation_request_for_child · method · L3943-L3944 — def delegation_request_for_child(self, **fields: Any) -> dict | None
delegation_tree · method · L3946-L3947 — def delegation_tree(self, root_frame_id: str) -> dict
delegation_budget · method · L3949-L3950 — def delegation_budget(self, root_frame_id: str) -> dict | None
delete_frame · method · L3952-L3953 — def delete_frame(self, frame_id: str) -> dict[str, Any]
get_frame · method · L3955-L3956 — def get_frame(self, frame_id: str) -> dict | None
get_artifact · method · L3958-L3959 — def get_artifact(self, artifact_id: str) -> dict | None
delete_artifact · method · L3961-L3962 — def delete_artifact(self, artifact_id: str) -> list[str]
rename_artifact · method · L3964-L3965 — def rename_artifact(self, artifact_id: str, filename: str) -> None
artifact_by_unique_filename · method · L3967-L3974 — def artifact_by_unique_filename( self, filename: str, root_frame_id: str | None = None ) -> dict | None
artifact_by_filename · method · L3976-L3983 — def artifact_by_filename( self, filename: str, root_frame_id: str | None = None, *, strict: bool = False ) -> dict | None
_artifact_write_scope · method · L3986-L3997 — def _artifact_write_scope( self, *, frame_id: str | None, root_frame_id: str | None, project_id: str | None, ) -> tuple[bool, str | None, str]
save_artifact · method · L3999-L4034 — def save_artifact( self, *, path: str, filename: str, content_type: str | None, size_bytes: int, checksum: str | None, producing_cell_id: str | None = None, frame_id: str | None = None, root_frame_id: str | None = None, project_id: str | None = None, artifact_id: str | None = None, is_user_upload: bool = False, priority: int = 0, env_snapshot_id: str | None = None, snapshot_path: str | None = None, source: Any = None, ) -> dict
record_cell_artifact · method · L4036-L4075 — def record_cell_artifact( self, *, path: str, filename: str, content_type: str | None, size_bytes: int, checksum: str | None, producing_cell_id: str | None, frame_id: str | None, root_frame_id: str | None = None, project_id: str | None = None, env_snapshot_id: str | None = None, snapshot_path: str | None = None, source: Any = None, input_version_ids: list[str] | tuple[str, ...] | None = None, preserve_filename: bool = False, preserve_content_type: bool = False, reuse_policy: str = "any", reuse_matching_head: bool = False, ) -> dict
commit_artifact_upload · method · L4077-L4080 — def commit_artifact_upload(self, **fields) -> dict
artifact_by_scope_filename · method · L4082-L4085 — def artifact_by_scope_filename(self, args, *kwargs) -> dict | None
rollback_artifact_upload · method · L4087-L4090 — def rollback_artifact_upload(self, **fields) -> bool
list_artifact_capture_observations · method · L4092-L4101 — def list_artifact_capture_observations( self, *, artifact_id: str | None = None, version_id: str | None = None, ) -> list[dict]
artifact_capture_observation_cursor · method · L4103-L4112 — def artifact_capture_observation_cursor( self, *, root_frame_id: str | None = None, project_id: str | None = None, ) -> int
artifact_capture_observations_since · method · L4114-L4127 — def artifact_capture_observations_since( self, cursor: int, *, root_frame_id: str | None, project_id: str, limit: int = 10_000, ) -> list[dict]
record_artifact_restore · method · L4129-L4158 — def record_artifact_restore( self, *, artifact_id: str, source_version_id: str, expected_latest_version_id: str, version_id: str, path: str, snapshot_path: str | None, size_bytes: int, checksum: str, frame_id: str | None, root_frame_id: str | None = None, project_id: str | None = None, publish=None, ) -> dict
materialise_artifact_version · method · L4160-L4187 — def materialise_artifact_version( self, *, source_version_id: str, artifact_id: str, version_id: str, filename: str, path: str, snapshot_path: str | None, frame_id: str | None, root_frame_id: str, project_id: str, producing_cell_id: str | None = None, publish=None, ) -> dict
upsert_env_snapshot · method · L4189-L4190 — def upsert_env_snapshot(self, snapshot: dict) -> str
delete_env_snapshots_if_unreferenced · method · L4192-L4193 — def delete_env_snapshots_if_unreferenced(self, snapshot_ids) -> int
get_env_snapshot · method · L4195-L4196 — def get_env_snapshot(self, snapshot_id: str) -> dict | None
env_snapshot_for_artifact · method · L4198-L4204 — def env_snapshot_for_artifact( self, artifact_id: str, version_id: str | None = None ) -> dict | None
list_artifacts · method · L4206-L4207 — def list_artifacts(self, filters: dict | None = None) -> list[dict]
browse_artifacts · method · L4209-L4228 — def browse_artifacts( self, *, project_id: str, filename_query: str | None = None, content_type: str | None = None, origin: str | None = None, before: tuple[int, str] | None = None, limit: int = 50, visible_to_user_id: str | None = None, ) -> list[dict]
list_artifact_names · method · L4230-L4231 — def list_artifact_names(self) -> list[dict]
artifact_names_for_frame · method · L4233-L4234 — def artifact_names_for_frame(self, frame_id: str) -> list[str]
resolve_artifact_path · method · L4236-L4237 — def resolve_artifact_path(self, ident: str) -> str | None
version_for_path · method · L4239-L4244 — def version_for_path( self, path: str, *, root_frame_id: str | None, project_id: str ) -> str | None
version_meta · method · L4246-L4247 — def version_meta(self, version_id: str) -> dict | None
set_version_source · method · L4249-L4250 — def set_version_source(self, version_id: str, source: Any) -> None
list_versions · method · L4252-L4253 — def list_versions(self, artifact_id: str) -> list[dict]
update_version_path · method · L4255-L4267 — def update_version_path( self, version_id: str, path: str, size_bytes: int | None = None, checksum: str | None = None, ) -> None
set_version_snapshot · method · L4269-L4270 — def set_version_snapshot(self, version_id: str, snapshot_path: str) -> None
set_priority · method · L4272-L4273 — def set_priority(self, artifact_id: str, priority: int) -> dict | None
set_latest_version · method · L4275-L4276 — def set_latest_version(self, artifact_id: str, version_id: str) -> dict | None
add_lineage_edge · method · L4278-L4291 — def add_lineage_edge( self, *, input_version_id: str, output_version_id: str, producing_cell_id: str | None = None, frame_id: str | None = None, ) -> None
lineage_inputs · method · L4293-L4302 — def lineage_inputs( self, version_id: str, *, producing_cell_id: str | None = None, ) -> list[dict]
lineage_edges_for · method · L4304-L4305 — def lineage_edges_for(self, version_id: str, direction: str) -> list[dict]
producing_cell_for_version · method · L4307-L4308 — def producing_cell_for_version(self, version_id: str) -> dict | None
add_note · method · L4311-L4318 — def add_note( self, *, project_id: str, content: str, title: str | None = None ) -> dict
list_notes · method · L4320-L4321 — def list_notes(self, project_id: str) -> list[dict]
project_of_note · method · L4323-L4324 — def project_of_note(self, note_id: str) -> str | None
delete_note · method · L4326-L4327 — def delete_note(self, note_id: str) -> None
get_setting · method · L4330-L4331 — def get_setting(self, key: str, default: str | None = None) -> str | None
set_setting · method · L4333-L4334 — def set_setting(self, key: str, value: str) -> None
delete_setting · method · L4336-L4337 — def delete_setting(self, key: str) -> None
delete_setting_if_value · method · L4339-L4340 — def delete_setting_if_value(self, key: str, expected_value: str) -> bool
get_share · method · L4343-L4344 — def get_share(self, share_id: str) -> dict | None
active_share_for_frame · method · L4346-L4347 — def active_share_for_frame(self, root_frame_id: str) -> dict | None
list_shares_for_frame · method · L4349-L4350 — def list_shares_for_frame(self, root_frame_id: str) -> list[dict]
list_shares · method · L4352-L4353 — def list_shares(self, *, include_revoked: bool = False) -> list[dict]
list_active_shares · method · L4355-L4356 — def list_active_shares(self) -> list[dict]
list_expired_shares · method · L4358-L4359 — def list_expired_shares(self, now_ms: int) -> list[dict]
begin_share_publish · method · L4361-L4376 — def begin_share_publish( self, *, share_id: str, root_frame_id: str, title: str | None, pending_snapshot_id: str, expires_at: int | None = None, ) -> dict
mark_share_ready · method · L4378-L4395 — def mark_share_ready( self, share_id: str, *, snapshot_id: str, bundle_sha256: str, bundle_size: int, projection_id: str, counts: dict | None = None, ) -> dict | None
mark_share_failed · method · L4397-L4398 — def mark_share_failed(self, share_id: str) -> None
mark_share_revoked · method · L4400-L4401 — def mark_share_revoked(self, share_id: str) -> None
delete_share · method · L4403-L4404 — def delete_share(self, share_id: str) -> None
list_model_profiles · method · L4410-L4411 — def list_model_profiles(self) -> list[dict]
set_model_profiles · method · L4413-L4414 — def set_model_profiles(self, profiles: list[dict]) -> None
mutate_model_profiles · method · L4416-L4417 — def mutate_model_profiles(self, fn)
set_permission_rule · method · L4420-L4435 — def set_permission_rule( self, , scope: str, scope_id: str = "", tool: str, pattern: str = "", decision: str, ) -> str
delete_permission_rule · method · L4437-L4438 — def delete_permission_rule(self, rule_id: str) -> None
get_permission_rule · method · L4440-L4441 — def get_permission_rule(self, rule_id: str) -> dict | None
get_permission_rules · method · L4443-L4444 — def get_permission_rules(self, *, scope: str, scope_id: str = "") -> list[dict]
list_permission_rules_for_frame · method · L4446-L4452 — def list_permission_rules_for_frame( self, *, root_frame_id: str | None = None, project_id: str | None = None ) -> dict
resolve_permission · method · L4454-L4467 — def resolve_permission( self, *, root_frame_id: str | None = None, project_id: str | None = None, tool: str, pattern_input: str = "", ) -> str
seed_default_permission_rules · method · L4469-L4470 — def seed_default_permission_rules(self, *, force: bool = False) -> None
create_permission_request · method · L4472-L4473 — def create_permission_request(self, **request: Any) -> dict
resolve_permission_request · method · L4475-L4498 — def resolve_permission_request( self, decision_id: str, *, state: str, scope: str | None = None, pattern: str | None = None, message: str | None = None, resolution_context: str | None = None, continuation_required: bool = False, expected_action_digest: str | None = None, resolved_at: int | None = None, ) -> dict
consume_restart_permission_grant · method · L4500-L4523 — def consume_restart_permission_grant( self, *, root_frame_id: str, tool: str, target: str = "", project_id: str | None = None, side_effect_class: str | None = None, resource_keys: list[str] | tuple[str, ...] | None = None, dangerous: bool = False, canonical_arguments: Any = None, consumed_at: int | None = None, ) -> dict | None
activate_restart_permission_continuation · method · L4525-L4534 — def activate_restart_permission_continuation( self, decision_id: str, *, expires_at: int | None = None, ) -> dict
get_permission_request · method · L4536-L4537 — def get_permission_request(self, decision_id: str) -> dict | None
permission_request_action_digest · method · L4539-L4540 — def permission_request_action_digest(self, decision_id: str) -> str
list_permission_requests · method · L4542-L4551 — def list_permission_requests( self, *, root_frame_id: str | None = None, state: str | None = None, ) -> list[dict]
_plan_row · method · L4554-L4555 — def _plan_row(self, row) -> dict
create_plan · method · L4557-L4578 — def create_plan( self, *, frame_id: str, project_id: str = "default", title: str | None, rationale: str | None, confidence: str | None, steps: list[dict], artifact_id: str | None = None, status: str = "draft", ) -> dict
get_plan · method · L4580-L4581 — def get_plan(self, plan_id: str) -> dict | None
get_plan_by_frame · method · L4583-L4585 — def get_plan_by_frame(self, frame_id: str) -> dict | None
pause_orphaned_executing_plans · method · L4587-L4589 — def pause_orphaned_executing_plans(self) -> int
list_plans · method · L4591-L4592 — def list_plans(self, frame_id: str, *, limit: int = 50) -> list[dict]
update_plan · method · L4594-L4615 — def update_plan( self, plan_id: str, *, title: str | None = None, rationale: str | None = None, confidence: str | None = None, steps: list[dict] | None = None, status: str | None = None, step_status: dict | None = None, artifact_id: str | None = None, ) -> None
compare_and_set_plan_status · method · L4617-L4629 — def compare_and_set_plan_status( self, plan_id: str, *, expected: str, new_status: str ) -> bool
set_plan_step_status · method · L4631-L4645 — def set_plan_step_status( self, plan_id: str, step_id: str, status: str, note: str | None = None ) -> dict | None
delete_plans_for_frame · method · L4647-L4648 — def delete_plans_for_frame(self, frame_id: str) -> None
create_folder · method · L4651-L4652 — def create_folder(self, *, project_id: str, name: str) -> dict
list_folders · method · L4654-L4655 — def list_folders(self, project_id: str) -> list[dict]
project_of_folder · method · L4657-L4658 — def project_of_folder(self, folder_id: str) -> str | None
rename_folder · method · L4660-L4661 — def rename_folder(self, folder_id: str, name: str) -> None
delete_folder · method · L4663-L4664 — def delete_folder(self, folder_id: str) -> None
set_frame_folder · method · L4666-L4667 — def set_frame_folder(self, frame_id: str, folder_id: str | None) -> None
add_memory · method · L4670-L4677 — def add_memory( self, *, content: str, block: str = "general", project_id: str = "default" ) -> dict
update_memory · method · L4679-L4692 — def update_memory( self, memory_id: str, *, content: str | None = None, block: str | None = None, project_id: str | None = None, ) -> dict | None
list_memories · method · L4694-L4697 — def list_memories( self, project_id: str | None = None, block: str | None = None ) -> list[dict]
resolve_memories · method · L4699-L4703 — def resolve_memories( self, project_id: str | None = None, block: str | None = None ) -> dict
delete_memory · method · L4705-L4708 — def delete_memory(self, memory_id: str, project_id: str | None = None) -> bool
memory_blocks · method · L4710-L4711 — def memory_blocks(self, project_id: str | None = None) -> list[dict]
set_feedback · method · L4714-L4715 — def set_feedback(self, frame_id: str, key: str, rating: str | None) -> None
list_feedback · method · L4717-L4718 — def list_feedback(self, frame_id: str) -> dict
add_annotation · method · L4721-L4746 — def add_annotation( self, *, root_frame_id: str, artifact_id: str, artifact_name: str | None, rel_x: float, rel_y: float, body: str, version_id: str | None = None, checksum: str | None = None, kind: str | None = None, locator: str | None = None, ) -> dict
get_annotation · method · L4748-L4749 — def get_annotation(self, annotation_id: str) -> dict | None
list_annotations · method · L4751-L4762 — def list_annotations( self, root_frame_id: str, *, artifact_id: str | None = None, status: str | None = None, ) -> list[dict]
update_annotation · method · L4764-L4777 — def update_annotation( self, annotation_id: str, *, body: str | None = None, status: str | None = None, expect_status: str | None = None, ) -> dict | None
mark_annotations_sent · method · L4779-L4780 — def mark_annotations_sent(self, annotation_ids: list[str]) -> None
reserve_with_admission · method · L4783-L4885 — def reserve_with_admission( self, *, reservation_id: str, root_frame_id: str, annotation_ids: list[str], ) -> tuple[bool, list[dict]]
update_admission · method · L4887-L4922 — def update_admission( self, reservation_id: str, *, root_frame_id: str, state: str | None = None, request_id: str | None = None, job_id: str | None = None, ) -> bool
abandon_admission · method · L4924-L4965 — def abandon_admission( self, reservation_id: str, *, root_frame_id: str, job_id: str ) -> bool
record_admission · method · L4967-L5000 — def record_admission( self, *, reservation_id: str, root_frame_id: str, annotation_ids: list[str], request_id: str | None = None, job_id: str | None = None, message_id: str | None = None, state: str = "reserved", ) -> None
set_admission_state · method · L5002-L5009 — def set_admission_state(self, reservation_id: str, state: str) -> None
get_admission · method · L5011-L5025 — def get_admission( self, reservation_id: str, *, root_frame_id: str | None = None ) -> dict | None
list_admissions · method · L5027-L5039 — def list_admissions(self, root_frame_id: str) -> list[dict]
recover_stranded_admissions · method · L5041-L5119 — def recover_stranded_admissions(self) -> int
reserve_annotations · method · L5121-L5128 — def reserve_annotations( self, *, root_frame_id: str, annotation_ids: list[str], reservation_id: str ) -> list[dict]
release_annotations · method · L5130-L5133 — def release_annotations( self, reservation_id: str, *, root_frame_id: str | None = None ) -> int
finalize_annotations_sent · method · L5135-L5150 — def finalize_annotations_sent( self, reservation_id: str, *, expected_ids: list[str] | None = None, root_frame_id: str | None = None, request_id: str | None = None, job_id: str | None = None, ) -> bool
annotation_is_reserved · method · L5152-L5153 — def annotation_is_reserved(self, annotation_id: str) -> bool
delete_annotation · method · L5155-L5156 — def delete_annotation(self, annotation_id: str) -> None
delete_unreserved_annotation · method · L5158-L5159 — def delete_unreserved_annotation(self, annotation_id: str) -> bool
index_datapro_result · method · L5162-L5184 — def index_datapro_result( self, query: str, structured_content: Mapping[str, Any], frame_id: str | None = None, artifact_id: str | None = None, occurrence_id: str | None = None, source_content: Any | None = None, ) -> dict[str, Any]
link_datapro_index_artifact · method · L5186-L5206 — def link_datapro_index_artifact( self, batch_id: str, artifact_id: str | None ) -> dict[str, Any]
search_datapro_index · method · L5208-L5234 — def search_datapro_index( self, query: str, limit: int = 20, frame_id: str | None = None, project_id: str | None = None, include_context: bool = False, ) -> dict[str, Any]
get_datapro_index_batch · method · L5236-L5237 — def get_datapro_index_batch(self, batch_id: str) -> dict[str, Any] | None
delete_datapro_index_batch · method · L5239-L5240 — def delete_datapro_index_batch(self, batch_id: str) -> None
search · method · L5243-L5309 — def search( self, query: str, limit: int = 20, *, visible_to_user_id: str | None = None ) -> dict
capability_state · method · L5312-L5321 — def capability_state( self, *, project_id: str | None = None, session_id: str | None = None, ) -> CapabilityStateService
skill_versions · method · L5323-L5326 — def skill_versions(self) -> SkillVersionRepository
set_capability_enabled · method · L5328-L5345 — def set_capability_enabled( self, kind: str, name: str, enabled: bool, *, scope: str = "global", scope_id: str = "", metadata: dict | None = None, ) -> dict
capability_snapshot · method · L5347-L5358 — def capability_snapshot( self, kind: str, names, *, project_id: str | None = None, session_id: str | None = None, ) -> dict[str, dict]
list_explicit_capability_states · method · L5360-L5371 — def list_explicit_capability_states( self, kind: str | None = None, *, scope: str | None = None, scope_id: str | None = None, ) -> list[dict]
list_agents · method · L5373-L5383 — def list_agents( self, *, project_id: str | None = None, session_id: str | None = None, include_disabled: bool = False, ) -> list[dict]
specialist_profiles · method · L5385-L5396 — def specialist_profiles( self, *, project_id: str | None = None, session_id: str | None = None, ) -> SpecialistProfileService
get_agent · method · L5398-L5409 — def get_agent( self, name: str, *, project_id: str | None = None, session_id: str | None = None, include_disabled: bool = False, ) -> dict | None
upsert_agent · method · L5411-L5428 — def upsert_agent( self, *, name: str, description: str = "", system_prompt: str = "", skill_names: list | None = None, connectors: list | None = None, unrestricted: bool = True, ) -> dict
update_agent · method · L5430-L5433 — def update_agent(self, name: str, **fields: Any) -> dict | None
delete_agent · method · L5435-L5436 — def delete_agent(self, name: str) -> None
list_connectors · method · L5439-L5440 — def list_connectors(self) -> list[dict]
get_connector · method · L5442-L5443 — def get_connector(self, connector_id: str) -> dict | None
upsert_connector · method · L5445-L5468 — def upsert_connector( self, *, connector_id: str, name: str, command, description: str = "", args=None, env=None, enabled: bool = True, ) -> dict: # Brokered here rather than in the repository: this facade owns the # SecretBroker, and the repository must keep returning the real env to # the callers that launch the server.
patch_connector · method · L5470-L5552 — def patch_connector( self, connector_id: str, *, name=None, description=None, command=None, args=None, enabled=None, env_updates=None, remove_env=None, ) -> dict | None
set_connector_enabled · method · L5554-L5555 — def set_connector_enabled(self, connector_id: str, enabled: bool) -> None
create_compute_job · method · L5558-L5559 — def create_compute_job(self, **kw) -> dict
update_compute_job · method · L5561-L5562 — def update_compute_job(self, job_id: str, **fields) -> dict | None
get_compute_job · method · L5564-L5565 — def get_compute_job(self, job_id: str) -> dict | None
artifact_write_scope · method · L5567-L5584 — def artifact_write_scope( self, *, frame_id: str | None = None, root_frame_id: str | None = None, project_id: str | None = None, ) -> tuple[bool, str | None, str]
compute_job_by_idempotency_key · method · L5586-L5589 — def compute_job_by_idempotency_key( self, key: str, owner_key: str | None = None, *, scoped: bool = True ) -> dict | None
live_compute_jobs · method · L5591-L5594 — def live_compute_jobs( self, owner_key: str | None = None, scoped: bool = False ) -> list[dict]
list_compute_jobs · method · L5596-L5597 — def list_compute_jobs(self, limit: int = 200) -> list[dict]
compute_jobs_for_owner · method · L5599-L5603 — def compute_jobs_for_owner( self, owner_key: str | None, limit: int = 200 ) -> list[dict]
append_compute_job_event · method · L5605-L5606 — def append_compute_job_event(self, job_id: str, kind: str, payload=None) -> int
compute_job_events · method · L5608-L5609 — def compute_job_events(self, job_id: str) -> list[dict]
delete_compute_job · method · L5611-L5612 — def delete_compute_job(self, job_id: str) -> None
delete_connector · method · L5614-L5619 — def delete_connector(self, connector_id: str) -> None: # Drop the credentials with the row. Otherwise a connector the user # removed leaves its env secrets in the keychain with nothing left in # the app that refers to them.
connector_env · method · L5621-L5623 — def connector_env(self, connector: dict) -> dict
archive_compaction · method · L5626-L5641 — def archive_compaction( self, , frame_id: str | None, summary: str, compacted: list[dict], project_id: str = "default", *metadata: Any, ) -> str
list_compaction_archives · method · L5643-L5644 — def list_compaction_archives(self, frame_id: str, *, limit: int = 50) -> list[dict]
upsert_endpoint · method · L5647-L5648 — def upsert_endpoint(self, name: str, **fields: Any) -> None
list_endpoints · method · L5650-L5651 — def list_endpoints(self) -> list[dict]
log_host_call · method · L5654-L5679 — def log_host_call( self, *, method: str, args: list, ok: bool, frame_id: str | None = None, result: Any = None, action_group_id: str | None = None, action_id: str | None = None, permission_decision_id: str | None = None, side_effect_class: str | None = None, resource_keys: list[str] | tuple[str, ...] | None = None, ) -> None
has_successful_bash_receipt · method · L5681-L5698 — def has_successful_bash_receipt( self, *, producing_cell_id: str, command_sha256: str, root_frame_id: str, branch_id: str, turn_id: str, ) -> bool
_refresh_scoped_views · method · L5701-L5784 — def _refresh_scoped_views( self, conn: sqlite3.Connection, scope: Mapping[str, Any] ) -> None
_query_view_only · method · L5786-L5809 — def _query_view_only(self) -> frozenset[str]
query · method · L5811-L5889 — def query( self, sql: str, params: list | None = None, limit: int | None = None, timeout_s: float = 5.0, scope: Mapping[str, Any] | None = None, ) -> list[dict]
schema · method · L5891-L5907 — def schema(self) -> dict[str, list[str]]
_TimeoutGuard · class · L5910-L5917 — class _TimeoutGuard
init · method · L5913-L5914 — def init(self, timeout_s: float)
call · method · L5916-L5917 — def call(self) -> int
_discard_store · function · L5924-L5930 — def _discard_store(store: Store) -> None
get_store · function · L5933-L5941 — def get_store(db_path: Path) -> Store