Registry / data / dagster-sling

dagster-sling

JSON →
library0.29.9pypypi✓ verified 86d ago

Dagster integration with Sling for ETL/ELT tasks, enabling ingestion and replication of data between databases and file systems. Current version 0.29.2, released as part of Dagster 1.13.2. Follows Dagster's release cadence.

pip install dagster-sling
INSTALL
IMPORT
SIG · DAGSTER-SLING
D
dagster-sling
datapythonv0.29.9
Install
12.3s avg
Import
3610ms
Disk
134MB
Pass rate
10/ 10
Env Coverage10 / 10
glibc
3.93.13
musl
3.93.13
Install & Compatibility
Where this runs
tested against v0.29.9 · 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.103.95 runs
installs and imports cleanly · install 0.0s · import 3.648s · 131.9MB
glibc
py 3.103.95 runs
installs and imports cleanly · install 12.3s · import 3.572s · 127MB
134MB installed
● package 134MB
Code
Verified usage

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

SlingResource
from dagster_sling import SlingResource
from dagster_sling.resources import SlingResource
SlingResource is at top-level module, not in a submodule
build_sling_replication
from dagster_sling import build_sling_replication

Define a Sling replication config and build assets from it using SlingResource.

from dagster_sling import SlingResource, build_sling_replication from dagster import Definitions, asset replication_config = { "source": { "conn": "postgres://user:pass@host:5432/db", "streams": { "public.users": None } }, "target": { "conn": "snowflake://user:pass@account/db/schema?warehouse=wh&role=role" }, "defaults": { "mode": "full-refresh", "object": "{stream_schema}_{stream_table}" } } sling_resource = SlingResource(connections=[ {"name": "MY_POSTGRES", "conn": "postgresql://user:pass@host:5432/db"}, {"name": "MY_SNOWFLAKE", "conn": "snowflake://user:pass@account/db/schema?warehouse=wh&role=role"} ]) assets = build_sling_replication( replication_config=replication_config, resource_def_key="sling", ) defs = Definitions(assets=assets, resources={"sling": sling_resource})
Debug
Known issues
gotchaThe replication config's source/target connections must reference connections defined in SlingResource by name. Hardcoding inline connection strings in the config is not supported.
fix
Define connections in SlingResource with a 'name' field, then use 'conn: NAME' in the replication config.
affects: >=0.20.0
breakingIn version 0.20.0, the API changed: the function to build assets from a Sling replication config was renamed from `sling_assets` to `build_sling_replication`, and the resource was renamed from `DagsterSlingResource` to `SlingResource`.
fix
Update imports and usage: from dagster_sling import SlingResource, build_sling_replication
affects: <0.20.0 -> >=0.20.0
gotchaSling must be installed separately via `pip install sling` or `curl -sSL https://slingdata.io/install.sh | bash`. The dagster-sling package does not install it automatically.
fix
Ensure Sling CLI is installed and available on PATH.
affects: all
deprecatedThe `mode` field in replication config defaults to `full-refresh`. For incremental loads, set `mode: incremental` and provide a `primary_key` and optional `updated_at`.
fix
Set `mode: incremental` and required keys.
affects: all
Errors
Common errors & fixes
ModuleNotFoundError: No module named 'sling'
Sling CLI is not installed.
fix
Run `pip install sling` or install via Sling's installation script.
dagster_sling.errors.SlingConnectionError: Connection 'MY_CONN' not found in sling resources
Replication config references a connection name that is not defined in SlingResource.
fix
Add the connection to SlingResource with a matching 'name' field.
TypeError: 'module' object is not callable
Attempting to call `dagster_sling.sling_assets` which was removed in 0.20.0.
fix
Use `build_sling_replication` instead.
Upgrade
Version history
0.29.9latest on PyPI · released Jun 11, 2026
Audit
Dependencies
dagsterrequiredCore dependency for Dagster integration
slingrequiredRequired for Sling CLI commands and replication
Agent activity
24 hits · last 30 days
node
22
OpenAI (training)
1
Resources
dagster-sling — pip install dagster-sling · libregistry