A Dagster integration for SQLMesh that provides seamless orchestration of SQLMesh models, schedules, and assets within Dagster workflows.
# Install the package
pip install dg-sqlmesh
# Or install from source
pip install -e .Our comprehensive documentation includes:
- Getting Started - Installation and setup guides
- User Guide - Core concepts and architecture
- Examples - Practical usage patterns
- Development - Contributing guidelines
- SQLMesh Integration - Native support for SQLMesh models and schedules
- Asset Management - Automatic asset creation from SQLMesh models
- Scheduling - Adaptive scheduling with Dagster's scheduling system
- Audit Integration - Built-in audit checks and validation
- Environment Management - Multi-environment support
dg-sqlmesh provides a clean abstraction layer between Dagster and SQLMesh:
- SQLMeshResource - Manages SQLMesh context and execution
- SQLMeshTranslator - Converts SQLMesh concepts to Dagster assets
- Factory Functions - Easy setup and configuration
pip install dg-sqlmeshgit clone https://github.com/fosk06/dagster-sqlmesh.git
cd dagster-sqlmesh
pip install -e .See our examples directory and documentation for comprehensive usage examples.
We welcome contributions! Please see our Contributing Guide for details.
This project is licensed under the MIT License - see the LICENSE file for details.
- Documentation: https://fosk06.github.io/dagster-sqlmesh/
- GitHub: https://github.com/fosk06/dagster-sqlmesh
- PyPI: https://pypi.org/project/dg-sqlmesh/
- Releases: https://github.com/fosk06/dagster-sqlmesh/releases