Type parameters
Constructors
constructor
• new AnswerExecution<Row, Kind>(transport, answer_id, initial?, recovery?, expectedKind?)
Type parameters
Parameters
Properties
resultContract
•Protected Readonly resultContract: Kind
transport
•Protected Readonly transport: AnswerExecutionTransport<Row>
answer_id
•Readonly answer_id: AnswerId<Row>
expectedKind
•Protected Optional expectedKind: Kind
Methods
snapshot
▸Readonly snapshot(): AnswerSnapshot<Row>
Returns
AnswerSnapshot<Row>
subscribe
▸Readonly subscribe(listener): () => void
Parameters
Returns
fn
▸ (): void
Returns
void
update
▸Protected update(change): void
Parameters
Returns
void
status
▸ status(request?): Promise<AnswerState<Row>>
Parameters
Returns
Promise<AnswerState<Row>>
explain
▸ explain():Promise<{ plan: AnswerPlan }>
Read the admitted plan through the execution’s current native access gate.
Returns
Promise<{ plan: AnswerPlan }>
matches
▸ matches(relation, bounds?): Promise<boolean>
Compare the admitted request at its owner, without disclosing relation
literals to recovery storage or submitting an unused reservation.
Parameters
Returns
Promise<boolean>
wait
▸ wait(options?): Promise<Extract<{ answer_id: AnswerId<Row> ; question_binding?: Readonly<{ function: string ; contract_digest: string }> ; deadline: string ; expires_at: string ; request_digest: string ; is_request_match?: boolean ; usage?: AnswerUsage } & { state: "ready" ; plan: AnswerPlan ; basis: { kind: "dataset_snapshots" ; local_revision?: string ; inputs: { table: string ; dataset: string ; version: string ; metadata: Value }[] } | { kind: "statement" ; provider: "snowflake" | "databricks" | "duckdb" | "clickhouse" } | { kind: "federated" ; local_revision?: string ; remote: { kind: "statement" ; provider: "snowflake" | "databricks" | "duckdb" | "clickhouse" ; tables: string[] }[] } ; completed_at: string } & Kind extends "complete" ? { result_kind: "complete" ; row_count: number ; result_digest: string } : { result_kind: "browse" ; row_count: null ; result_digest?: undefined }, { state: "ready" }>>
Parameters
Returns
Promise<Extract<{ answer_id: AnswerId<Row> ; question_binding?: Readonly<{ function: string ; contract_digest: string }> ; deadline: string ; expires_at: string ; request_digest: string ; is_request_match?: boolean ; usage?: AnswerUsage } & { state: "ready" ; plan: AnswerPlan ; basis: { kind: "dataset_snapshots" ; local_revision?: string ; inputs: { table: string ; dataset: string ; version: string ; metadata: Value }[] } | { kind: "statement" ; provider: "snowflake" | "databricks" | "duckdb" | "clickhouse" } | { kind: "federated" ; local_revision?: string ; remote: { kind: "statement" ; provider: "snowflake" | "databricks" | "duckdb" | "clickhouse" ; tables: string[] }[] } ; completed_at: string } & Kind extends "complete" ? { result_kind: "complete" ; row_count: number ; result_digest: string } : { result_kind: "browse" ; row_count: null ; result_digest?: undefined }, { state: "ready" }>>
observe
▸ observe(options?): AsyncGenerator<Extract<{ answer_id: AnswerId<Row> ; question_binding?: Readonly<{ function: string ; contract_digest: string }> ; deadline: string ; expires_at: string ; request_digest: string ; is_request_match?: boolean ; usage?: AnswerUsage } & { state: "ready" ; plan: AnswerPlan ; basis: { kind: "dataset_snapshots" ; local_revision?: string ; inputs: { table: string ; dataset: string ; version: string ; metadata: Value }[] } | { kind: "statement" ; provider: "snowflake" | "databricks" | "duckdb" | "clickhouse" } | { kind: "federated" ; local_revision?: string ; remote: { kind: "statement" ; provider: "snowflake" | "databricks" | "duckdb" | "clickhouse" ; tables: string[] }[] } ; completed_at: string } & Kind extends "complete" ? { result_kind: "complete" ; row_count: number ; result_digest: string } : { result_kind: "browse" ; row_count: null ; result_digest?: undefined }, { state: "ready" }>, any, unknown>
Observe local custody revisions on the existing subscription transport.
Every revision hides managed pages before a full native status check.
Stopping observation leaves the durable execution and its custody intact.
Parameters
Returns
AsyncGenerator<Extract<{ answer_id: AnswerId<Row> ; question_binding?: Readonly<{ function: string ; contract_digest: string }> ; deadline: string ; expires_at: string ; request_digest: string ; is_request_match?: boolean ; usage?: AnswerUsage } & { state: "ready" ; plan: AnswerPlan ; basis: { kind: "dataset_snapshots" ; local_revision?: string ; inputs: { table: string ; dataset: string ; version: string ; metadata: Value }[] } | { kind: "statement" ; provider: "snowflake" | "databricks" | "duckdb" | "clickhouse" } | { kind: "federated" ; local_revision?: string ; remote: { kind: "statement" ; provider: "snowflake" | "databricks" | "duckdb" | "clickhouse" ; tables: string[] }[] } ; completed_at: string } & Kind extends "complete" ? { result_kind: "complete" ; row_count: number ; result_digest: string } : { result_kind: "browse" ; row_count: null ; result_digest?: undefined }, { state: "ready" }>, any, unknown>
result
▸ result(options?): Promise<AnswerResult<Row, Kind>>
Select the typed result handle without collecting rows. Dynamic discovery uses this union.
Parameters
Returns
Promise<AnswerResult<Row, Kind>>
cancel
▸ cancel():Promise<AnswerControl<Row>>
Returns
Promise<AnswerControl<Row>>
release
▸ release():Promise<AnswerControl<Row>>
Returns
Promise<AnswerControl<Row>>