Looks up a variable in the context.

Build a test `AppState` with explicitly-set capability flags so unit tests don't depend on probe semantics. Production goes through `AppState::new` wh

Offsets the query by `count` rows.

Get an optional string field.

Returns a reversed view of this value. This is implemented for the following types with the following behaviors: undefined or none: value returned u

Right aligns the given const (i.e. known at compile time) action text to a fixed width defined by ACTION_WIDTH. Use it for the first column of progre

Returns the canonical schema identifier.

Builds a `SchemaStore` pre-loaded with one frontier entry.

If the value is a string, return it. This will also perform a lossy string conversion of bytes from utf-8.

Issues a fresh cancellation token from this source.

Updates attributes of the given span. The `attrs_updater` closure receives a mutable reference to the current attributes and should modify them in pl

Validate an incoming event against a recorded event.

Clamp a client-provided `first` value to the [1, MAX_PAGE_SIZE] range.

Create a new Tuple with a fast clone

Helper to create progress message

helper func to create nodes with dependencies

Minimal backend: node row only, empty columns and edges. Use for tests that care about capability gating, not sub-resource extraction.

Check execute of statement with `SELECT 21 + 21` query.

List epoch files matching `{SCHEMA_VERSION}_{N}.parquet` in `dir`, sorted ascending.

Get the default ADBC statement options

`GET /api/v1/groups/:id?first=<n>` — full group detail with inline member-model list. `owner` is `null` when no owner-shaped fields are set on the gr

Gets a specific invocation totals metrics (stored in the root invocation span).

`GET /api/v1/metrics/:id` — full metric detail. `depends_on` and `referenced_by` are unbounded.

Get and consume an optional value by name or next positional argument

`GET /api/v1/semantic_models/:id` — full semantic model detail. Semantic models are spec-only: no `execution_info`, `catalog`, `freshness`, `columns`

`GET /api/v1/snapshots/:id` — full snapshot detail. `execution_info` is `null` when `dbt_rt.run_results` has no row for this snapshot; `catalog` is `

Get a mutable reference to the inner attribute.

Stringify nested columns, ignoring struct fields dbt Core flattens struct fields as JSON strings for certain adapters, only keeping the root-level co

`GET /api/v1/models` — cursor-paginated, filterable, sortable list of model nodes. Response shape (ADR-6 envelope): ```json { "data": [...], "page_in

Safely evaluate a Python expression to a literal value This mimics Python's `ast.literal_eval` - only supports literal structures (strings, bytes, nu

Make a simple model row (name match).

Build a test `AppState` with explicitly-set capability flags so unit tests don't depend on probe semantics. Production goes through `AppState::new` wh

Normalize SQL by compacting multiple spaces and newlines into a single space. This ensures consistent checksums regardless of formatting differences d

Parse a JSON semantic query specification. Expected format: ```json { "metrics": ["revenue", "order_count"], "group_by": ["TimeDimension('metric_time

Stores a variable in the context.

Pre-saves structured event attributes to be immediately consumed by tracing span/log call. If you want to emit a log or create a new span, prefer - `

Returns a reference to the underlying node as a trait object. This method allows accessing common functionality across all node types through the `In

Assert no calls to a specific method were made.

Build parent and child dependency maps from the nodes. Returns a tuple of (parent_map, child_map) where: - parent_map: maps each node ID to a list of

Helper: build a NodeResolver with given compile_or_test flag, then call `set_defer_context` with the given nodes/sorted/frontier, and return it for te

Wrapper around [`std::fs::canonicalize`] that returns a useful error in case of failure. This is the same as dbt_common::stdfs::canonicalize inlined i

Returns a [Span] corresponding to the current instruction.