dagster-snowflake

What it is and what it does

dagster-snowflake is a Dagster integration library that bridges Snowflake data warehouse with Dagster's asset-oriented orchestration model. It provides resource abstractions and connectors that let you declare Snowflake tables and queries as Dagster assets, then orchestrate their creation, updates, and dependencies alongside other data assets in a unified pipeline.

The package sits on top of Dagster (a cloud-native data pipeline orchestrator) and Snowflake's Python connector libraries. It's designed for teams building data platforms where Snowflake is the central warehouse—you define your data transformations as Python functions decorated with Dagster's asset syntax, and the integration handles the Snowflake connection and execution details. This lets you manage lineage, testing, scheduling, and observability for Snowflake workloads within Dagster's web UI and CLI.

Use it for:

• Build Snowflake-backed data pipelines with Dagster's declarative asset model, managing dependencies and scheduling from a single control plane
• Integrate Snowflake queries and transformations into multi-tool data workflows that also include Python, dbt, or other data tools
• Test Snowflake data assets locally during development before deploying to production orchestration
• Monitor Snowflake asset lineage and data quality issues through Dagster's observability and cataloging features
• Automate Snowflake table refreshes and transformations on a schedule or event-driven basis via Dagster's job definitions

Worth the install?

AI-flagged interpretation of the facts on this page — verify before relying

Integrates Snowflake with Dagster's data orchestration framework, enabling you to build and manage data pipelines that read from and write to Snowflake as part of a larger asset-driven workflow.

Yes, if you are already using Dagster for data orchestration and need to integrate Snowflake workloads. The package is actively maintained, has no known vulnerabilities, and low install friction. Install only if Dagster is already your orchestration framework; it is not a standalone Snowflake client.

Install

dagster-snowflake on PyPI

pip install dagster-snowflake

uv add dagster-snowflake

poetry add dagster-snowflake

Installing dagster-snowflake

Before you install

Low friction install with a wheel distribution. Actively maintained with a recent release and strong upstream project health (15996 GitHub stars, active repository). Requires Dagster and Snowflake connector libraries as runtime dependencies.

License in practice

Apache 2.0 permissive license allows use in commercial and open-source projects without significant restrictions, though you must include a copy of the license and note any modifications.

Quickstart

pip install dagster-snowflake

import dagster as dg
from dagster_snowflake import SnowflakeResource

@dg.asset
def my_snowflake_asset(snowflake: SnowflakeResource):
    with snowflake.get_connection() as conn:
        conn.execute("SELECT * FROM my_table")

Requires Python 3.10 or later (supports up to 3.14). Snowflake account credentials and network access to Snowflake must be configured separately.

Verify before relying

• Specific Snowflake resource configuration options and authentication methods supported by this integration version
• Whether this package provides asset materialization templates or requires manual SQL definition
• Performance characteristics and connection pooling behavior with large-scale Snowflake workloads

Package facts

Evidence: dagster_snowflake-0.29.18-py3-none-any.whl

Tags

More Distributed Computing packages