Registry / workflow / dagster-embedded-elt

dagster-embedded-elt

library0.29.1pypypiunverified

A Dagster library for performing ETL/ELT tasks, providing integrations with tools like dbt, Sling, and Airbyte. This version (0.29.1) is part of the Dagster 1.13.1 release, compatible with Python 3.10-3.14. The library follows Dagster's release cadence with monthly minor releases and patch releases as needed.

workflow data devops

pip install dagster-embedded-elt

github ↗package ↗homepage ↗

INSTALL

IMPORT

SIG · DAGSTER-EMBEDDED-E

dagster-embedded-elt

workflowpythonv0.29.1

Install

16.5s avg

Import

—

Disk

166MB

Pass rate

10/ 10

Env Coverage10 / 10

glibc

3.9–3.13

musl

3.9–3.13

Install & Compatibility

Where this runs

tested against v0.29.1 · pip install

no network on importno background threads

Install × environment matrix

Each cell = how many times install + import succeeded across repeated harness runs. Partial = flaky.
glibc = Debian/Ubuntu slim · musl = Alpine Linux

musl

py 3.10–3.915 runs

installs and imports cleanly · install 0.0s · import 0.000s · 158.3MB

glibc

py 3.10–3.915 runs

installs and imports cleanly · install 16.5s · import 0.000s · 153MB

166MB installed

● package 166MB

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

EmbeddedEltDbtResource

✓ from dagster_embedded_elt import EmbeddedEltDbtResource

✗ from dagster_embedded_elt.dbt import EmbeddedEltDbtResource

Define a Sling-based ELT asset that copies data from Postgres to Snowflake.

from dagster import AssetExecutionContext, Definitions from dagster_embedded_elt.sling import build_sling_asset, SlingResource replication_config = { "source": { "type": "postgres", "connection_string": "postgresql://user:pass@localhost:5432/source" }, "target": { "type": "snowflake", "connection_string": "snowflake://user:pass@account/db/schema?warehouse=wh&role=role" }, "streams": { "public.my_table": { "object": "my_schema.my_table", "mode": "full_refresh" } } } sling_resource = SlingResource() my_asset = build_sling_asset( asset_key="my_table", source_connection_string=os.environ.get("SOURCE_CONN", ""), target_connection_string=os.environ.get("TARGET_CONN", ""), replication_config=replication_config ) defs = Definitions(assets=[my_asset], resources={"sling": sling_resource})

Debug

Known issues

breakingIn dagster-embedded-elt versions prior to 0.29.0, the Sling resource used `SlingResource` from `dagster_embedded_elt.sling.resources`. In 0.29.0, the import path changed to `dagster_embedded_elt.sling`. Update imports to avoid breaking changes.

fix

Replace `from dagster_embedded_elt.sling.resources import SlingResource` with `from dagster_embedded_elt.sling import SlingResource`.

affects: <0.29.0

deprecatedThe `build_sling_asset` function's `mode` parameter in the replication config is deprecated in favor of `replication_mode`. The old `mode` key will be removed in a future version.

fix

Use `replication_mode` instead of `mode` in your replication config streams.

affects: >=0.28.0

gotchaWhen using `build_sling_asset` with a `SlingResource`, ensure you pass the resource in the Definitions. The asset will fail at runtime if the resource key does not match.

fix

Always include `resources={"sling": sling_resource}` in your Definitions, and use the default resource key 'sling' or set `resource_key` in `build_sling_asset`.

affects: all

breakingThe `EmbeddedEltDbtResource` has been renamed from `DbtCliResource` in dagster-embedded-elt <=0.27.0. Existing code must be updated.

fix

Replace `from dagster_embedded_elt.dbt import DbtCliResource` with `from dagster_embedded_elt.dbt import EmbeddedEltDbtResource`.

affects: <=0.27.0

Upgrade

Version history

0.29.1latest on PyPI · released Apr 17, 2026

Audit

Dependencies

dagsterrequiredCore Dagster framework required

dbt-coreoptionalRequired for dbt integration

slingoptionalRequired for Sling integration

Agent activity

21 hits · last 30 days

node

OpenAI (training)

Resources

githubhttps://github.com/dagster-io/dagster ↗

packagehttps://pypi.org/project/dagster-embedded-elt/ ↗

homepagehttps://dagster.io ↗