Create a new `BufReader` from a buffered reader

TODO: Box the CommonArgs because it's a 1Kb struct

Get and consume an optional value by name from kwargs

Helper to call [Adapter::call_method_impl] with jinja-valued arguments.

package_name -> macro_names

Build an instance of the metadata adapter if supported.

Create a `RelationConfigLoader` for Databricks views

Prune rows whose `unique_id` is not in `alive_ids`. No-op when `alive_ids` is None.

Remove a value at a given index, shifting subsequent elements to the left.

Helper to run a stress test with various buffer capacities This will aggressively test the terminator state transition since buffers are small and we

Strip the dependency package root from paths that are stored relative to the root project.

Recursively traverse view definitions starting from the given relations. For each fetched view definition, parses its SQL via `sqlparser` (`dbt_adapt

Return a column from `batch` by name if it matches `expected_type`, else a null array.

Helper to create a composite selector

Wrapper around [`std::fs::File::create`] that returns a useful error in case of failure.

Return the difference of the set and another iterable.

Get and consume a value by name or next positional argument

Get DB config by key

`GET /api/v1/models/:id` — full model detail. `execution_info` and `catalog` are `null` when the corresponding parquet tables are absent or empty. `

`GET /api/v1/tests/:id` — full test detail. Returns a discriminated union keyed on `resource_type`: - `"test"` → [`DataTestDetail`] - `"unit_test"` →

generate the unique id for a dbt resource (can be made more extensible for each type of node)

See [Path::is_absolute] for documentation.

Returns true if this category represents an operation that mutates state.

Check that a string is a valid SQL identifier (alphanumeric + underscore).

Returns the current line number (1-based).

Helper to create a test Recording from events

Build a minimal `IncrementalState` whose `validate()` will pass given the real `profiles.yml` and `dbt_project.yml` paths in `project_root`.

Returns the canonical table identifier.

Set the unique node id associated with this context. Re-assigning the node id will panic in debug builds.

Registers all features of this crate with an [`Environment`]. All the filters that are available will be added, same with global functions that exist

Returns a human-readable status string for the freshness outcome.

Helper to assert decoded records match expected 2D data.

Call the type # Arguments `positional_args` - The positional arguments to call the type with `kwargs` - The keyword arguments to call the type with

Creates a relation based on the adapter type This is a wrapper around the [create_relation] function that is supposed to be used outside the context

Helper function to handle default_to logic for meta and tags Uses the existing merge functions for proper merging behavior

Builds an empty `SchemaStore` with `ParquetCache` format rooted at `dir`.

If this error represents an exit-with-status request, returns the status code. Returns [None] for all other errors.

Converts the compiler into the instructions.

Flatten the type # Arguments `self` - The type to flatten

Returns the base context of the state and add file_stack to it. This should always be a mutable map wrapped in a Value:from_object

Get the configuration for a fully qualified name (fqn) This method is recommended for nodes that don't derive from SQL files or where the node name d

Get a global variable.

Returns the path for the current node corresponding to `path_kind`, relative to `in_dir`. Callers that have an [`ExecutionPhase`] can convert it via

`GET /api/v1/sources/:id` — full source detail. `freshness` is `null` when `dbt.source_freshness` has no row for this source; `catalog` is `null` whe

Inserts a relation of [Arc<dyn BaseRelation] along with an optional <Arc<dyn BaseRelationConfig>> if applicable

The equivalent of tuple(zip(self.keys(), self.values())).