Resolve storage locations from environment variables. `DATA_BUCKET` is the entity-level setting. `BUCKET_NAME` remains supported for v2.5 com

Resolve product/runtime identity from environment variables. Defaults preserve the v2.5 SoloLakehouse local reference behavior.

Scan an entire Iceberg table and return as a pandas DataFrame.

Append *df* to the Bronze Iceberg table for *source* and return a logical path.

Append rejected records to the Bronze rejected Iceberg table.

Return a mock Iceberg catalog that captures append calls.

Return the effective entity data bucket.

Raise if any gap between consecutive dates exceeds max_gap_days.

Raise if any date in date_col is later than datetime.date.today().

Raise if any of the specified columns contain nulls.

Raise if df is missing any column from expected_columns.

Create a HiveCatalog backed by Hive Metastore and MinIO (S3-compatible). All parameters fall back to environment variables so Docker and local-de

Return the effective Trino user for this runtime identity.

Return quality metrics dict and log it.

Return True if Bronze already contains a row ingested today.

Build one feature row per ECB rate-change event.

Run a SQL statement via Trino REST API and poll until completion.

Replace all rows in an Iceberg table (Silver / Gold pattern).

Run DAX-specific bronze checks.

Run ECB-specific bronze checks.

Train a binary classifier with TimeSeriesSplit cross-validation.

Cast nanosecond-precision timestamp columns to microseconds. Iceberg v1/v2 only supports microsecond (us) timestamp precision. Python 3.11+ d

Host-side TCP endpoint for the published Postgres port (Compose maps PG_PORT).

Create namespace if it does not already exist (idempotent).

Serialize with model_dump and include underscore aliases.

Transform DAX bronze rows into cleaned silver rows.

Transform ECB bronze rows into cleaned silver rows.

Return True if Bronze already contains a row ingested today.

Return a PostgreSQL dollar-quoted literal safe for passwords with quotes or $.

Load .env from the repo root if present (same logic as verify-demo.py).

Apply ALTER USER using trusted in-container psql (avoids quoting issues).

Return the default audit bucket for a data bucket.

Return the default MLflow artifact bucket for a data bucket.

Return the default MLflow artifact root URI for an artifact bucket.

Return the default warehouse URI for a data bucket.

Return the effective entity audit bucket.

Return the effective MLflow artifact bucket.

Return the effective MLflow default artifact root URI.

Return the effective Hive/Trino warehouse URI.