Fluid Forge
Why Forge
Concepts
Get Started
  • Consume a Data Product
  • See it run
  • Demos
  • Local (DuckDB)
  • Source-Aligned (Postgres → DuckDB)
  • AI Forge + Data Models
  • MCP Output Port — Serve to AI Agents
  • 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
  • Agent Policy (concept)
  • MCP Output Port — Serve to Agents
  • MCP deep-dive
  • AI-assisted authoring
  • LLM providers & backends
  • Overview
  • Quickstart
  • Examples
  • Your own CI
  • Your own scaffolding
  • Custom validator
  • Apply hook
  • Reference
  • Overview
  • Architecture
  • GCP (BigQuery)
  • AWS (S3 + Athena)
  • Snowflake
  • Local (DuckDB)
  • Custom Providers
  • Roadmap
GitHub
Why Forge
Concepts
Get Started
  • Consume a Data Product
  • See it run
  • Demos
  • Local (DuckDB)
  • Source-Aligned (Postgres → DuckDB)
  • AI Forge + Data Models
  • MCP Output Port — Serve to AI Agents
  • 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
  • Agent Policy (concept)
  • MCP Output Port — Serve to Agents
  • MCP deep-dive
  • AI-assisted authoring
  • LLM providers & backends
  • Overview
  • Quickstart
  • Examples
  • Your own CI
  • Your own scaffolding
  • Custom validator
  • Apply hook
  • Reference
  • Overview
  • Architecture
  • GCP (BigQuery)
  • AWS (S3 + Athena)
  • Snowflake
  • Local (DuckDB)
  • Custom Providers
  • Roadmap
GitHub
  • Introduction

    • Home
    • Why Fluid Forge
    • 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

    • Consume a Data Product
    • Product Types — SDP, ADP, CDP
  • Walkthroughs

    • Walkthrough: Local Development
    • Source-Aligned: Postgres → DuckDB → Parquet
    • AI Forge And Data-Model Journeys
    • Walkthrough: MCP Output Port
    • 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
    • Core workflow

      • fluid init
      • fluid demo
      • fluid forge
      • fluid validate
      • fluid plan
      • fluid apply
      • fluid diff
      • fluid status
    • Build & ship

      • fluid bundle
      • fluid generate
      • fluid generate artifacts
      • fluid validate-artifacts
      • fluid verify-signature
      • fluid generate iac
      • fluid generate-airflow
      • fluid generate-pipeline
      • fluid viz-graph
      • fluid publish
      • fluid ship
      • fluid rollback
      • fluid schedule-sync
    • AI & Agents

      • fluid ai
      • fluid agents
      • fluid mcp
      • fluid memory
      • fluid stats
      • fluid skills
    • Quality & governance

      • fluid test
      • fluid verify
      • fluid contract-tests
      • fluid contract-validation
      • fluid policy
      • fluid policy check
      • fluid policy compile
      • fluid policy apply
    • Standards & interoperability

      • fluid odps
      • fluid odps-bitol
      • fluid odcs
      • fluid export
      • fluid export-odps
      • fluid exporters
      • fluid import
      • fluid market
      • fluid datamesh-manager
    • Project & workspace

      • fluid product-new
      • fluid product-add
      • fluid workspace
      • fluid contract
      • fluid split
      • fluid config
      • fluid providers
      • fluid plugins
      • fluid provider-init
      • fluid auth
      • fluid secrets
      • fluid ide
      • fluid scaffold-ci
      • fluid scaffold-composer
      • fluid scaffold-ide
      • fluid docs
      • fluid runs
      • fluid retention
      • fluid describe
      • fluid doctor
      • fluid roadmap
      • fluid version
    • Catalog adapters

      • Source Catalog Integration (V1.5)
      • Publishing to a Catalog — Overview
      • BigQuery Catalog
      • Snowflake Horizon Catalog
      • Databricks Unity Catalog
      • Google Dataplex Catalog
      • AWS Glue Data Catalog
      • DataHub Catalog
      • Data Mesh Manager Catalog
      • OpenMetadata 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
    • Write a contract that consumes another contract
    • Generate per-environment overlays
  • 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
  • AI & Agents

    • MCP Server
    • Built-in And Custom Forge Guidance
    • Forge Discovery Guide
    • Forge Memory Guide
    • Authoring Forge Tools
    • Guided fluid forge UX
    • LLM Providers
    • LiteLLM Backend
    • Capability Warnings
    • Cost Tracking
    • FLUID Forge Contract GPT Packet
    • Agentic Primitives
  • Operate & Deploy

    • Airflow Integration
    • Blueprints
    • Source-Aligned Acquisition
  • Govern & Secure

    • Governance, Compliance & the Business Case
    • Governance & Compliance
    • Network Safety
    • Credential Resolver — Security Model
  • Configuration & Reference

    • Environment Variables
    • Typed Errors
    • Typed CLI Errors
    • API Stability — fluid_build.api
  • Architecture & Releases

    • V1.5 Catalog Integration — Architecture Deep-Dive
    • V1.5 + V2 Hardening — Release Notes
  • Project

    • Contributing to Fluid Forge
    • Fluid Forge Docs Baseline: CLI 0.9.0
    • Fluid Forge Docs Baseline: CLI 0.8.11
    • Fluid Forge Docs Baseline: CLI 0.8.10
    • Fluid Forge Docs Baseline: CLI 0.8.9
    • Fluid Forge Docs Baseline: CLI 0.8.8
    • Fluid Forge Docs Baseline: CLI 0.8.7
    • Fluid Forge Docs Baseline: CLI 0.8.6
    • Fluid Forge Docs Baseline: CLI 0.8.5
    • Fluid Forge Docs Baseline: CLI 0.8.4
    • 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

Vision & Roadmap

Why we built this

Modern data engineering still feels like 2015 infrastructure work. You write SQL in dbt. You write IAM in Terraform. You write DAGs in Airflow. You write policies in OPA. You write masking rules in your warehouse's UI. Five tools, five languages, five ways for those four things to drift from each other. When the schema changes, someone has to remember to update all four, or production breaks at 3am.

Fluid Forge starts from a different premise: a data product is a contract, not a pipeline. A contract describes what the product is — its schema, its quality rules, its access policy, its AI gating, its sovereignty constraints — in one file. The pipeline is what falls out when a CLI compiles that contract for a target cloud.

That inversion changes how teams work. Instead of writing infrastructure code, you write the product specification. Instead of debugging four-tool drift, you change the contract and re-apply. Instead of asking "who owns this DAG?" you ask "who owns this product?" and the contract tells you.

What we believe

These are the convictions baked into Forge. If you disagree with any of them, Forge is probably the wrong choice for your team — and that's fine.

  1. Schema, infrastructure, orchestration, policy, and AI gating belong in one file. Splitting them across four tools is the source of most data-product incidents.
  2. Local-first development is non-negotiable. You should be able to ship a working data product on your laptop with no cloud account, no credit card, no waiting on a platform team. pipx install "data-product-forge[local]" and you're three commands from a deployed product.
  3. Multi-cloud is the default state, not a migration. Most companies are already multi-cloud (one team on Snowflake, another on BigQuery, a third on S3+Athena). Tools that pretend you're on a single cloud are lying to you.
  4. Governance is not a separate phase. It's part of the contract from line one. Adding accessPolicy and agentPolicy after the fact is when teams discover that everything they shipped six months ago is non-compliant.
  5. AI access deserves the same gates as human access. Agents reading your data are not a niche use case anymore — they're often the largest consumer. agentPolicy makes their boundaries declarative.
  6. Open source, Apache-2.0, no contributor agreement. No vendor capture at the contract layer. The CLI is a community project; nobody can decide tomorrow that Forge is now Forge Cloud-only.
  7. Honest comparisons. We don't pretend Forge wins everywhere. The vs alternatives page tells you when not to use Forge — that's how a tool earns trust.

Who this is for

  • Data engineers at companies with two or more clouds, or compliance pressure (SOX, GDPR, HIPAA), or AI agents reading the data
  • Platform teams building a self-service data platform — Forge is the contract layer your internal users write against
  • Data product owners who don't want to learn five tools to ship one product
  • OSS contributors who think the four-tool stack is broken and want to help fix it

Who this is NOT for (yet)

  • Single-warehouse, single-team analytics shops with no governance pressure — dbt is simpler. Adopt Forge when (or if) the cross-tool drift starts to bite.
  • Sub-second streaming workloads — Forge's batch-and-mini-batch model fits 5-minute to 24-hour latency. For sub-second, look at Materialize / RisingWave.
  • Teams that need a hosted control plane today — Forge is currently CLI + CI. Hosted UI is on the roadmap, not shipped.

What problem it solves

Most teams still build data products with a pile of provider-specific scripts, IAM glue, orchestration code, and validation logic. That slows down delivery and makes cloud changes expensive.

Fluid Forge shifts that work into one contract-driven workflow:

fluidVersion: "0.7.4"
kind: DataProduct
id: analytics.customers
name: Customer Analytics

metadata:
  owner:
    team: data-engineering

exposes:
  - exposeId: customers_table
    kind: table
    binding:
      platform: gcp
      location:
        dataset: analytics
        table: customers
    contract:
      schema:
        - name: id
          type: INTEGER
          required: true
        - name: email
          type: STRING
          sensitivity: pii

The contract becomes the source of truth for validation, planning, execution, verification, testing, and publishing.

Core principles

Declarative first

Describe the desired outcome. Let the CLI validate and execute it consistently.

Local first

The recommended docs path starts locally:

fluid init my-project --quickstart
cd my-project
fluid validate contract.fluid.yaml
fluid plan contract.fluid.yaml
fluid apply contract.fluid.yaml --yes

AI is optional

Use deterministic scaffolding with fluid init, or opt into guided generation with:

fluid forge
fluid forge --domain finance

Same contract, different targets

Provider changes should not force a new mental model. The docs keep the same command language across local, GCP, AWS, and Snowflake.

Lifecycle

Design

fluid init my-project --quickstart
fluid forge --llm-provider openai --llm-model gpt-4.1-mini

Validate and govern

fluid validate contract.fluid.yaml
fluid policy-check contract.fluid.yaml

Plan

fluid plan contract.fluid.yaml
fluid diff contract.fluid.yaml --env prod

Deploy

fluid apply contract.fluid.yaml --yes
fluid verify contract.fluid.yaml
fluid generate schedule --scheduler airflow

Operate

fluid test contract.fluid.yaml
fluid publish contract.fluid.yaml
fluid market --search "customer analytics"

Versioning in the docs

  • Current CLI release baseline: 0.10.0
  • Current scaffolded contract examples: fluidVersion: 0.7.5

That split is intentional. The CLI release and the contract schema version move on related but different timelines.

Roadmap

MilestoneNotes
0.8.0 baseline11-stage production pipeline, signed bundles, rollback, DMM Access lineage, Jenkins generation defaults
0.8.4–0.10.0 (current)OpenTofu/IaC autogeneration for cloud apply, the MCP output-port gateway with runtime agentPolicy enforcement, three plugin extension points + a companion SDK, and pluggable modeling techniques / metadata-source adapters for fluid forge data-model
Plugin governance + spec exportersShipped in 0.10.0 — operator allow/block gate (FLUID_PLUGINS_ALLOWLIST / FLUID_PLUGINS_BLOCKLIST), the fluid plugins roster, and fluid exporters (ODCS / ODPS / ODPS-Bitol reclassified from providers to spec exporters)
Streaming Kafka → Iceberg sinkShipped in 0.9.0 — opt-in via fluidVersion: 0.7.5 (Kafka-Connect + Debezium Iceberg sinks, Confluent Tableflow plugin)
Azure providerOn the roadmap
Databricks + broader platformsFuture work

Get involved

  • Getting Started
  • CLI Reference
  • Providers
  • Contributing

Need help?

  • Questions or ideas? Start a GitHub Discussion
  • Bug or unexpected behavior? Open an issue
  • Want to contribute? See the contributing guide
Edit this page on GitHub
Last Updated: 6/27/26, 4:58 PM
Contributors: Jeff Watson, jeffwatson-ai, fas89, Claude Opus 4.7, Claude Opus 4.7 (1M context)
Prev
Forge Data Model
Next
Playground