dagster-soda
dagster-soda integrates Soda Core data quality checks with Dagster. It provides the SodaScanComponent, a Dagster component that runs Soda Core scans and maps SodaCL check results to Dagster asset checks.
Installation
pip install dagster-soda
Note: dagster-soda requires soda-core 3.x (the soda.scan API). It pins soda-core>=3.0,<4 by default.
Usage
Component: SodaScanComponent
Configure a SodaScanComponent in your Dagster project to:
- Point at SodaCL YAML check files and a Soda
configuration.yml - Map Soda dataset names to Dagster asset keys
- Run scans and report pass/fail as Dagster asset check results
Scaffolding with the CLI
Use the Dagster CLI to scaffold a new Soda scan component in your project (requires dagster-dg-cli):
dg scaffold defs dagster_soda.SodaScanComponent <path>
Example (scaffold into a folder named soda_checks under your defs directory):
dg scaffold defs dagster_soda.SodaScanComponent soda_checks
This generates:
- A defs.yaml with default attributes (
checks_paths,configuration_path,data_source_name,asset_key_map) - A checks.yml template with example SodaCL (e.g.
checks for my_table: - row_count > 0)
Edit the generated files to match your data source and checks, then load your definitions as usual.
Minimal defs.yaml example
type: dagster_soda.SodaScanComponent
attributes:
checks_paths:
- checks.yml
configuration_path: configuration.yml
data_source_name: my_datasource
asset_key_map:
my_table: my_table
Documentation
The docs for dagster-soda can be found here.
1 maintainer
Release files for dagster-soda 0.29.18
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| dagster_soda-0.29.18.tar.gz | 201.5 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| dagster_soda-0.29.18-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 213.7 kB
Release files / dagster_soda-0.29.18.tar.gz
| Download URL | dagster_soda-0.29.18.tar.gz |
|---|---|
| Size | 201.5 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
00959a9f61ede81188e616ecd68031deb98ad0d18e55655ecc7276066875ba73
|
|
BLAKE2b-256 checksum How to use checksums |
a25bbb8989b031d03cfd62ab430422d421928cf7072eeac37f6be5115a14b8bd
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/7.0.0 CPython/3.12.14
|
Release files / dagster_soda-0.29.18-py3-none-any.whl
| Download URL | dagster_soda-0.29.18-py3-none-any.whl |
|---|---|
| Size | 12.2 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
f7eb30110149128ce5cbbd7b9cc54a08186cd67710054581be1a585a9d45c729
|
|
BLAKE2b-256 checksum How to use checksums |
736b4593ddab4d0284e0b3520b75fa4bba4b50dbd56d4f4a31252a1e3c54e1bd
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/7.0.0 CPython/3.12.14
|
