Fluid Forge
Get Started
See it run
  • Local (DuckDB)
  • Source-Aligned (Postgres → DuckDB)
  • AI Forge + Data Models
  • GCP (BigQuery)
  • Snowflake Team Collaboration
  • Declarative Airflow
  • Orchestration Export
  • Jenkins CI/CD
  • Universal Pipeline
  • 11-Stage Production Pipeline
  • Catalog Forge End-to-End
CLI Reference
  • Overview
  • Quickstart
  • Examples
  • Your own CI
  • Your own scaffolding
  • Custom validator
  • Apply hook
  • Reference
Demos
  • Overview
  • Architecture
  • GCP (BigQuery)
  • AWS (S3 + Athena)
  • Snowflake
  • Local (DuckDB)
  • Custom Providers
  • Roadmap
GitHub
GitHub
Get Started
See it run
  • Local (DuckDB)
  • Source-Aligned (Postgres → DuckDB)
  • AI Forge + Data Models
  • GCP (BigQuery)
  • Snowflake Team Collaboration
  • Declarative Airflow
  • Orchestration Export
  • Jenkins CI/CD
  • Universal Pipeline
  • 11-Stage Production Pipeline
  • Catalog Forge End-to-End
CLI Reference
  • Overview
  • Quickstart
  • Examples
  • Your own CI
  • Your own scaffolding
  • Custom validator
  • Apply hook
  • Reference
Demos
  • Overview
  • Architecture
  • GCP (BigQuery)
  • AWS (S3 + Athena)
  • Snowflake
  • Local (DuckDB)
  • Custom Providers
  • Roadmap
GitHub
GitHub
  • Introduction

    • Home
    • Getting Started
    • Snowflake Quickstart
    • See it run
    • Forge Data Model
    • Vision & Roadmap
    • Playground
    • FAQ
  • Concepts

    • Concepts
    • Builds, Exposes, Bindings
    • What is a contract?
    • Quality, SLAs & Lineage
    • Governance & Policy
    • Agent Policy (LLM/AI governance)
    • Providers vs Platforms
    • Fluid Forge vs alternatives
  • Data Products

    • Product Types — SDP, ADP, CDP
  • Walkthroughs

    • Walkthrough: Local Development
    • Source-Aligned: Postgres → DuckDB → Parquet
    • AI Forge And Data-Model Journeys
    • Walkthrough: Deploy to Google Cloud Platform
    • Walkthrough: Snowflake Team Collaboration
    • Declarative Airflow DAG Generation - The FLUID Way
    • Generating Orchestration Code from Contracts
    • Jenkins CI/CD for FLUID Data Products
    • Universal Pipeline
    • The 11-Stage Pipeline
    • End-to-End Walkthrough: Catalog → Contract → Transformation
  • CLI Reference

    • CLI Reference
    • fluid init
    • fluid demo
    • fluid forge
    • fluid skills
    • fluid status
    • fluid validate
    • fluid plan
    • fluid apply
    • fluid generate
    • fluid generate artifacts
    • fluid validate-artifacts
    • fluid verify-signature
    • fluid generate-airflow
    • fluid generate-pipeline
    • fluid viz-graph
    • fluid odps
    • fluid odps-bitol
    • fluid odcs
    • fluid export
    • fluid export-opds
    • fluid publish
    • fluid datamesh-manager
    • fluid market
    • fluid import
    • fluid policy
    • fluid policy check
    • fluid policy compile
    • fluid policy apply
    • fluid contract-tests
    • fluid contract-validation
    • fluid diff
    • fluid test
    • fluid verify
    • fluid product-new
    • fluid product-add
    • fluid workspace
    • fluid ide
    • fluid ai
    • fluid memory
    • fluid mcp
    • fluid scaffold-ci
    • fluid scaffold-composer
    • fluid scaffold-ide
    • fluid docs
    • fluid config
    • fluid split
    • fluid bundle
    • fluid auth
    • fluid doctor
    • fluid providers
    • fluid provider-init
    • fluid roadmap
    • fluid version
    • fluid runs
    • fluid retention
    • fluid secrets
    • fluid stats
    • fluid contract
    • fluid ship
    • fluid rollback
    • fluid schedule-sync
    • Catalog adapters

      • Source Catalog Integration (V1.5)
      • BigQuery Catalog
      • Snowflake Horizon Catalog
      • Databricks Unity Catalog
      • Google Dataplex Catalog
      • AWS Glue Data Catalog
      • DataHub Catalog
      • Data Mesh Manager Catalog
    • CLI by task

      • CLI by task
      • Add quality rules
      • Add agent governance
      • Debug a failed pipeline run
      • Switch clouds with one line
  • Recipes

    • Recipes
    • Recipe — add a quality rule
    • Recipe — switch clouds with one line
    • Recipe — tag PII in your schema
  • SDK & Plugins

    • SDK & Plugins
    • Quickstart — your first plugin
    • Examples

      • Runnable examples
      • Example: hello-scaffold — the minimal viable plugin
      • Example: gitlab-ci-scaffold — generate a complete CI project
      • Example: steward-validator — a custom governance rule
      • Example: prod-key-guard — apply-time invariant check
    • Journeys

      • Journeys
      • Your own CI/CD

        • You have your own CI/CD setup, no problem
        • GitLab CI — the bundle template
        • GitHub Actions — the bundle template
        • Jenkins — the bundle template
        • CircleCI — the bundle template
      • You have a strict project layout, no problem
      • You have governance rules, no problem
      • You want a check at apply time, no problem
    • Reference

      • Reference
      • Roles reference
      • Entry points reference
      • Trust model
      • Packaging
      • Companion packages
  • Providers

    • Providers
    • Provider Architecture
    • GCP Provider
    • AWS Provider
    • Snowflake Provider
    • Local Provider
    • Creating Custom Providers
    • Provider Roadmap
  • Advanced

    • Blueprints
    • Governance & Compliance
    • Airflow Integration
    • Built-in And Custom Forge Guidance
    • FLUID Forge Contract GPT Packet
    • Forge Discovery Guide
    • Forge Memory Guide
    • LLM Providers
    • Capability Warnings
    • LiteLLM Backend (opt-in)
    • MCP Server
    • Credential Resolver — Security Model
    • Cost Tracking
    • Agentic Primitives
    • Typed Errors
    • Typed CLI Errors
    • Authoring Forge Tools
    • Source-Aligned Acquisition
    • API Stability — fluid_build.api
    • Guided fluid forge UX
    • V1.5 Catalog Integration — Architecture Deep-Dive
    • V1.5 + V2 Hardening — Release Notes
  • Project

    • Contributing to Fluid Forge
    • Fluid Forge Docs Baseline: CLI 0.8.3
    • Fluid Forge Docs Baseline: CLI 0.8.0
    • Fluid Forge Docs Baseline: CLI 0.7.11
    • Fluid Forge Docs Baseline: CLI 0.7.9
    • Fluid Forge v0.7.1 - Multi-Provider Export Release

Databricks Unity Catalog

Source-side catalog adapter for Databricks Unity Catalog. Reads tables, columns, lineage, column tags, column masks, business glossary terms, and certifications.

Recommended for: Databricks-native teams already using Unity for governance. Forge-cli reads Unity's metadata-as-truth and emits a Fluid contract that respects every column mask, sensitive tag, and certification mark.

Install

pip install "data-product-forge[databricks]"

Adds the databricks-sdk runtime dep. Default install ships without it; the adapter raises CatalogConfigError with the install command if called without the extra.

Privileges to grant

The adapter is read-only on metadata — never reads data values.

-- Run as a Unity Metastore Admin or workspace admin.
GRANT USE CATALOG       ON CATALOG main         TO `analyst@example.com`;
GRANT USE SCHEMA        ON SCHEMA main.biz_lab  TO `analyst@example.com`;
GRANT BROWSE            ON CATALOG main         TO `analyst@example.com`;
GRANT SELECT            ON SCHEMA main.biz_lab  TO `analyst@example.com`;
-- (SELECT is required for the system tables that back Unity's
-- INFORMATION_SCHEMA-equivalent views; the adapter doesn't issue
-- SELECT on user data tables.)

For lineage:

-- The adapter reads system.access.table_lineage / column_lineage.
GRANT USE CATALOG ON CATALOG system           TO `analyst@example.com`;
GRANT USE SCHEMA  ON SCHEMA   system.access   TO `analyst@example.com`;
GRANT SELECT      ON TABLE    system.access.table_lineage  TO `analyst@example.com`;
GRANT SELECT      ON TABLE    system.access.column_lineage TO `analyst@example.com`;

If lineage privileges are missing, the adapter soft-fails on lineage reads (forge still works; downstream DV2 link inference falls back to FK constraints only).

Authentication methods

MethodWhen to useSetup
pat ★Default for CLI useGenerate a personal access token from the workspace UI.
oauth_m2mService-principal in CIService principal client ID + secret.
oauth_userSSO with browserOAuth user-to-machine; pops a browser.
azure_cliAzure-Databricks via Azure ADInherits the local az login token.
aws_iamDatabricks-on-AWS via IAMInherits the local IAM identity.

★ pat is the recommended path for local CLI use. CI / production should prefer oauth_m2m with a service principal.

Setup

fluid ai setup --source unity --name unity-prod
# ? Catalog: databricks
# ? Workspace host: https://dbc-12345.cloud.databricks.com
# ? Auth method:
#   ★ pat (recommended for local)
#     oauth_m2m
#     oauth_user
#     azure_cli
#     aws_iam
# ? Token: ******                    (stored in OS keyring)
# ? Default catalog: main
# ? Default schema:  biz_lab
# ✓ Saved to ~/.fluid/sources.yaml

Or set env vars:

export DATABRICKS_HOST=https://dbc-12345.cloud.databricks.com
export DATABRICKS_TOKEN=dapi...                # for pat auth
export DATABRICKS_CLIENT_ID=...                # for oauth_m2m
export DATABRICKS_CLIENT_SECRET=...

End-to-end demo

# 1. Configure once.
fluid ai setup --source unity --name unity-prod

# 2. Forge a Dimensional model from a Unity schema.
fluid forge data-model from-source \
  --source unity \
  --credential-id unity-prod \
  --database main --schema biz_lab \
  --technique dimensional \
  -o biz_lab.fluid.yaml

# 3. Generate dbt transformations.
fluid generate transformation biz_lab.fluid.yaml -o ./dbt_biz_lab --dbt-validate

What lands where

Unity sourceForge output
Table commentOSIDataset.fields[].expression.description
Column commentOSIDataset.fields[].expression.description
Primary key constraintOSIDataset.primary_key[]
Foreign key constraintOSIRelationship[] (deterministic)
Column tag domainmetadata.domain + industry hint
Column tag pii / phi / pciagentPolicy.sensitiveData[]
Column maskRecorded as masked: true in metadata; modeler does NOT invent the masked value's content; mask declaration carried forward to dbt meta:
system.access.table_lineagemetadata.lineage.upstream[]
Certification (Unity Marketplace)metadata.certification

Column masks are honored, not bypassed

If Unity has a column mask on email, the adapter records the mask declaration in metadata; the modeler does NOT try to invent the masked column's content (it can't — the adapter never reads data values). The Fluid contract carries the mask declaration so downstream tools (dbt Cloud, Databricks SQL warehouses) enforce.

Common errors

CatalogConfigError: databricks-sdk missing

Run pip install "data-product-forge[databricks]".

CatalogPermissionError: USE SCHEMA on main.biz_lab required

Suggestion list contains:

GRANT USE SCHEMA ON SCHEMA main.biz_lab TO `analyst@example.com`;

CatalogConnectionError: 401 Unauthorized

PAT expired or revoked. Generate a new one in the workspace UI (User Settings → Access tokens) and rerun fluid ai setup --source.

Lineage tab empty in the forged contract

Likely missing SELECT ON system.access.table_lineage. Adapter soft-fails; forge still works. Granting upgrades subsequent runs.

See also

  • Catalog index
  • fluid forge data-model from-source
Edit this page on GitHub
Last Updated: 4/26/26, 10:42 PM
Contributors: fas89, Claude Opus 4.7
Prev
Snowflake Horizon Catalog
Next
Google Dataplex Catalog