dagster-rocky
Dagster integration for Rocky, the typed graph between your code and your warehouse.
dagster-rocky wraps the rocky CLI as a Dagster ConfigurableResource and exposes Rocky-managed
tables as materializable Dagster assets. Compile-time contracts, column-level lineage, schema-drift
detection, quality check results, and per-model cost surface as native Dagster events, so the
guarantees Rocky enforces at compile time appear directly in the Dagster asset graph.
Install
uv add dagster-rocky
You'll also need the Rocky CLI on your $PATH:
https://github.com/rocky-data/rocky/releases?q=engine
Quick start (component)
Add a defs.yaml next to your other Dagster definitions:
type: dagster_rocky.RockyComponent
attributes:
binary_path: rocky
config_path: config/rocky.toml
models_dir: models
Dagster's component loader will:
- Run
rocky discover(androcky compile, when models are present) and cache the result. - Build one subset-aware
multi_assetper Rocky group, with declaredrow_count/column_match/freshnesschecks per table. - On materialization, shell out to
rocky run --filter <key>=<value>for the selected subset and yieldMaterializeResult+AssetCheckResultevents with rich metadata.
Quick start (resource)
import dagster as dg
from dagster_rocky import RockyResource
rocky = RockyResource(
binary_path="rocky",
config_path="config/rocky.toml",
timeout_seconds=3600,
)
defs = dg.Definitions(resources={"rocky": rocky})
Then in an asset:
@dg.asset
def acme_orders(rocky: RockyResource) -> dg.MaterializeResult:
result = rocky.run(filter="tenant=acme")
return dg.MaterializeResult(
metadata={"tables_copied": result.tables_copied, "duration_ms": result.duration_ms},
)
Public API
| Symbol | Purpose |
|---|---|
RockyResource |
ConfigurableResource wrapping the Rocky CLI |
RockyComponent |
State-backed Dagster component that loads Rocky tables as assets |
RockyDagsterTranslator |
Subclass to customize asset key / group / tag mapping |
RockyMetadataSet |
Namespaced metadata (source_id, strategy, watermark, …) |
load_rocky_assets() |
Functional helper that returns AssetSpec for each Rocky table |
emit_materializations() / emit_check_results() |
Convert a RunResult into Dagster events |
check_metadata() |
Build a metadata mapping for a single Rocky CheckResult |
cost_metadata_from_optimize() |
Extract per-model cost recommendations from OptimizeResult |
parse_rocky_output() |
Auto-detect a Rocky JSON payload and return the matching Pydantic model |
Documentation
- Dagster Integration docs: resource, component, translator, schedules, sensors, pipes, and more
- DEVELOPMENT.md: local setup, architecture, testing
- CHANGELOG.md: release notes
Related projects
- Rocky: the Rust SQL transformation engine
- Rocky VS Code extension: VS Code extension with LSP and AI features
License
Apache 2.0
1 maintainer
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file dagster_rocky-1.51.0.tar.gz.
File metadata
- Download URL: dagster_rocky-1.51.0.tar.gz
- Upload date:
- Size: 343.3 kB
- Tags: Source
- Uploaded using Trusted Publishing? Yes
- Uploaded via: twine/6.1.0 CPython/3.13.13
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
d59509cca0d218fe4eb3b1e43eba0860d3232be3c71b959aca05e8c670e10c2c
|
|
| MD5 |
d0c876135854bd6e21ef17f59a838b41
|
|
| BLAKE2b-256 |
92e2a74dc25c98732537e8b39fa8aef17027b729d6deeeb0fcf30fe84316bff2
|
Provenance
The following attestation bundles were made for dagster_rocky-1.51.0.tar.gz:
Publisher:
dagster-release.yml on rocky-data/rocky
-
Statement:
-
Statement type:
https://in-toto.io/Statement/v1 -
Predicate type:
https://docs.pypi.org/attestations/publish/v1 -
Subject name:
dagster_rocky-1.51.0.tar.gz -
Subject digest:
d59509cca0d218fe4eb3b1e43eba0860d3232be3c71b959aca05e8c670e10c2c - Sigstore transparency entry: 1920513061
- Sigstore integration time:
-
Permalink:
rocky-data/rocky@032674640304e83603fa595c45150937064c6c6b -
Branch / Tag:
refs/tags/dagster-v1.51.0 - Owner: https://github.com/rocky-data
-
Access:
public
-
Token Issuer:
https://token.actions.githubusercontent.com -
Runner Environment:
github-hosted -
Publication workflow:
dagster-release.yml@032674640304e83603fa595c45150937064c6c6b -
Trigger Event:
push
-
Statement type:
File details
Details for the file dagster_rocky-1.51.0-py3-none-any.whl.
File metadata
- Download URL: dagster_rocky-1.51.0-py3-none-any.whl
- Upload date:
- Size: 116.1 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? Yes
- Uploaded via: twine/6.1.0 CPython/3.13.13
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
4a493e80d86b2bdfcbfbbffbcb9632f74723f79b80bfbad95df3e9027f37d67f
|
|
| MD5 |
537e9ab2173128e2ea716419eb4f9d1f
|
|
| BLAKE2b-256 |
2c45b4e52be1e01c1004704d06863959da02205ff9e0f109c6ee8b2578805429
|
Provenance
The following attestation bundles were made for dagster_rocky-1.51.0-py3-none-any.whl:
Publisher:
dagster-release.yml on rocky-data/rocky
-
Statement:
-
Statement type:
https://in-toto.io/Statement/v1 -
Predicate type:
https://docs.pypi.org/attestations/publish/v1 -
Subject name:
dagster_rocky-1.51.0-py3-none-any.whl -
Subject digest:
4a493e80d86b2bdfcbfbbffbcb9632f74723f79b80bfbad95df3e9027f37d67f - Sigstore transparency entry: 1920513185
- Sigstore integration time:
-
Permalink:
rocky-data/rocky@032674640304e83603fa595c45150937064c6c6b -
Branch / Tag:
refs/tags/dagster-v1.51.0 - Owner: https://github.com/rocky-data
-
Access:
public
-
Token Issuer:
https://token.actions.githubusercontent.com -
Runner Environment:
github-hosted -
Publication workflow:
dagster-release.yml@032674640304e83603fa595c45150937064c6c6b -
Trigger Event:
push
-
Statement type:
