Skip to content

Welcome to dg-sqlmesh Documentation

Get up and running with dg-sqlmesh in minutes. Learn the basics and create your first SQLMesh-Dagster integration.

Comprehensive guide covering all aspects of SQLMesh integration with Dagster, from basic concepts to advanced features.

Complete API documentation for all functions, classes, and methods in the dg-sqlmesh package.

Practical examples and code samples showing how to use dg-sqlmesh in real-world scenarios.

What is dg-sqlmesh?

dg-sqlmesh is a powerful Python package that provides seamless integration between SQLMesh and Dagster, enabling you to orchestrate SQLMesh models as Dagster assets with full support for audits, metadata, and adaptive scheduling.

📚 Documentation

📖 Full Documentation →

Our comprehensive documentation includes:

  • Getting Started - Installation and setup guides
  • User Guide - Core concepts and architecture
  • Examples - Practical usage patterns
  • Development - Contributing guidelines

🎯 Key Features

  • Individual Asset Control : Each SQLMesh model becomes a separate Dagster asset
  • Automatic Materialization : SQLMesh models are automatically converted to Dagster assets
  • Audit Integration : SQLMesh audits become Dagster AssetCheckSpec with proper result handling
  • Adaptive Scheduling : Intelligent schedule creation based on SQLMesh cron analysis
  • External Asset Mapping : Support for external sources with Jinja2 templating
  • Component System : Declarative YAML configuration for easy integration

🚀 Why Choose dg-sqlmesh?

  • Seamless Integration

Bridge the gap between SQLMesh's powerful data modeling and Dagster's orchestration capabilities.

  • Production Ready

Built with enterprise-grade features including concurrency control, error handling, and monitoring.

  • Developer Friendly

Simple factory functions, comprehensive examples, and clear documentation.

  • Extensible

Custom translators, external asset mapping, and flexible configuration options.

Quick Installation

pip install dg-sqlmesh

Basic Usage

from dg_sqlmesh import sqlmesh_definitions_factory

# All-in-one factory with external asset mapping!
defs = sqlmesh_definitions_factory(
    project_dir="sqlmesh_project",
    gateway="postgres",
    external_asset_mapping="target/main/{node.name}",
    concurrency_limit=1,
    group_name="sqlmesh",
    enable_schedule=True,
)

Current Version

Latest Release: v1.9.2

Features: Complete documentation system, GitHub Pages infrastructure, and improved maintainability

Get Started

Ready to begin? Choose your path:

Community & Support


Pro Tip: Check out our examples for ready-to-use code snippets and comprehensive documentation.