Mark the recorder as closed. After calling this, further events will be silently dropped. The channel closes when this EventRecorder (and all clones)

Resolve the fully qualified materialization macro function name according to dbt rules Rules: - When require_explicit_package_overrides_for_builtin_m

Returns the error message without the error code prefix. Includes file location and backtrace if present. This is used by tracing layers where the cod

Turn the tokenised CLI list (already split on whitespace by Clap) into a `SelectExpression` tree. Outer level**: each whitespace‑separated token is a

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

Render a template from a string.

Serialize a value with the specified mode Note: This assumes config structs do NOT have #[skip_serializing_none], so None values are serialized as nu

Adds a cause to this error, replacing the existing cause if any Note: if you attach a cause to an error, make sure you don't format the cause into th

Write rows to a parquet file using serde_arrow + ZSTD compression. Writes in chunks of 256 rows to keep memory bounded for large batches.

Attempt to initialize a [`Database`] using the values provided to this builder using the provided [`Driver`].

Build the graph

Retrieves the schema from the cache, hydrating it from disk on first use.

Get the recording header.

Return all keys in the map.

Load defer state from disk, cloud, or reuse a previously loaded state. Returns the previous state (if available) and the filtered defer nodes (ephemer

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

Test if a string value matches this type.

Assert that at least one SQL sent to `adapter.execute()` contains the given substring (case insensitive).

Build the shared test DAG used by the multi-seed tests. ```text src_a src_b src_c iso_a / \ / \ / \

Returns the cached [`SchemaEntry`] for `lookup_key`, if present. Deserializes the IPC bytes on first call; subsequent calls return the cached [`Schem

Alternative lookup strategy without error handling exclusively for context resolution. The main difference is that the return value will be `None` if

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

Convert an ODBC return code to a [`Result`] from `adbc_core`. This is the only place where we convert ODBC return codes to `Result` and the only depe

Flushes all in-memory parquet-cache entries to disk as new epoch files. - `Selected` entries → `compiled_state/schemas_analyzed/{N}.parquet` - all ot

Schema as string or error

Sets the underlying value atomically.

Applies the filter to a value and argument.

Create a new `Reader` from a non-buffered reader If `R: BufRead` consider using [`Self::build_buffered`] to avoid unnecessary additional buffering, a

Returns the canonical catalog identifier.

Test env reader that filters empty strings (like non_empty_env).

Compatibility check used for typechecking (permissive). This is intentionally *not* the same as [`Type::is_subtype_of`]. The subtype relation is used

Main entry: A base64 DER is the body of a PEM - If BOTH headers present -> return as-is. - If NEITHER header present -> classify and wrap with the mat

Parse the SQL type and return it along with a boolean indicating if its nullable.

Create a new instance from the current jinja state.

dt.replace(year=?, month=?, day=?, hour=?, minute=?, second=?, microsecond=?, tzinfo=?)

Strip resource paths from the beginning of a reference path This function tries to find which resource path is a prefix of the ref_path and returns th

Update the map with the contents of another map.

Parse and use the provided URI ([`Self::uri`]). Returns an error when parsing fails.

Attaches another error as source to this error.

Build the context map.

"chrono_dt" is a helper method that returns a naive DateTime if we're naive, or the local datetime if we're aware. This is mostly for read-only field

Push a flat column to the new fields and columns.

Small helpers for safely composing inline-string SQL from request inputs. Phase 2a uses string-interpolated SQL. The DuckDB instance is in-memory and

Extracts a resource type subtree from a raw `dbt_project.yml` into a RawProjectConfig struct for building unrendered configs.

generate the fqn

Identifiers as string or error

Acquire the lock on recorded calls and return a guard wrapper. The returned [`ObservedCalls`] holds the mutex and dereferences to `[JinjaCall]`, so a