Dagster is joining PrefectRead the announcement →

Connect to everything
in your data ecosystem

Dagster integrates with every major tool in the modern data and AI stack—so your orchestrator isn’t the blocker, it’s the bridge.

Explore Integrations

Explore Integrations

Explore docs, guides, and examples for Dagster’s integrations—spanning orchestration, ingestion, storage, transformation, and beyond.

Airbyte

Orchestrate Airbyte connections and schedule syncs alongside upstream or downstream dependencies.

ETL / Reverse ETL

Anthropic

Integrate Anthropic’s Claude AI models into Dagster pipelines for advanced conversational AI capabilities.

Other

Apache Airflow

Accelerate the migration of Airflow DAGs to Dagster assets with opinionated tooling.

Other

AWS Athena

Connect to AWS Athena and analyze data in Amazon S3 using standard SQL.

Storage

AWS CloudWatch

Send Dagster logs to AWS CloudWatch for centralized logging and monitoring.

Logging & Monitoring

AWS ECR

Manage container images with AWS Elastic Container Registry from Dagster pipelines.

Other

AWS EMR

Run petabyte-scale processing with AWS EMR, Spark, Hive, Presto, and more.

Compute

AWS Glue

Initiate AWS Glue jobs, pass parameters, and stream logs and structured messages back to Dagster.

Compute

AWS Lambda

Use serverless functions to execute external code in your pipelines.

Compute

AWS Redshift

Use Redshift’s data warehousing capabilities in Dagster workflows.

Storage

AWS S3

Read and write objects to durable AWS S3 storage from Dagster pipelines.

Storage

AWS Secrets Manager

Manage, retrieve, and rotate credentials, API keys, and other secrets.

Other

AWS Systems Parameter Store

Manage and retrieve parameters stored in AWS Systems Manager Parameter Store.

Other

Azure Data Lake Storage Gen 2 (ADLS2)

Get utilities for ADLS2 and Blob Storage.

Storage

Bash / Shell

Execute a Bash or shell command directly or from a script file.

Compute

Census

Trigger Census syncs from within your Dagster pipelines.

ETL / Reverse ETL

Clickhouse

Read and write natively to ClickHouse from software-defined assets.

Storage

Cube

Push changes from upstream data sources to Cube’s semantic layer.

Other

Databricks

Initiate Databricks jobs, pass parameters, and stream logs back into Dagster.

Compute

Datadog

Publish metrics to Datadog and centralize monitoring metrics.

Logging & Monitoring

dbt Cloud

Run dbt Cloud jobs as part of your data pipeline.

ETL / Reverse ETL

dbt™

Put your dbt transformations to work directly from Dagster.

ETL / Reverse ETL

Delta Lake

Integrate your pipelines into Delta Lake.

Storage

dlt

Easily ingest and replicate data between systems with dlt through Dagster.

ETL / Reverse ETL

Docker

Run external processes in Docker containers directly from Dagster.

Compute

DuckDB

Read and write natively to DuckDB from software-defined assets.

Storage

Fivetran

Orchestrate Fivetran connectors and schedule syncs with upstream or downstream dependencies.

ETL / Reverse ETL

GCP BigQuery

Integrate Dagster with GCP BigQuery.

Storage

GCP Dataproc

Integrate Dagster with GCP Dataproc.

Compute

GCP GCS

Integrate Dagster with Google Cloud Storage.

Storage

Gemini

Integrate Google’s Gemini AI models into Dagster pipelines.

Other

Github

Integrate with GitHub Apps and automate operations in repositories.

Other

Great Expectations

Yield an expectation and its output with all relevant metadata.

Other

Hashicorp Vault

Centrally manage credentials and certificates, then use them in pipelines.

Other

Hex

Work in Hex, then pull Hex apps into your pipeline as software-defined assets.

Hightouch

Trigger syncs and monitor them until they complete.

ETL / Reverse ETL

Jupyter

Eliminate the tedious productionization of Jupyter notebooks.

Compute

Kubernetes

Launch Kubernetes pods and execute external code directly from Dagster.

Compute

lakeFS

Bring version control and complete lineage to the data lake.

Storage

Looker

Monitor a Looker instance as assets in Dagster alongside other data assets.

Business Intelligence

Meltano

Tap into open-source configurable ETL and the Singer integration library.

ETL / Reverse ETL

Microsoft SharePoint

Automate file operations, folder management, and data extraction through Graph API.

Storage

Microsoft Teams

Keep your team up to speed with Teams messages.

Alerting

MLflow

Streamline productionizing, maintaining, and monitoring machine-learning models.

Modal

Run serverless Python functions at scale with Modal.

Compute

OpenAI

Integrate OpenAI calls into Dagster pipelines without breaking the bank.

Other

Open Metadata

Configure and schedule metadata and profiler workflows from the OpenMetadata UI.

Metadata & Data Quality

Pagerduty

Centralize monitoring with the Dagster PagerDuty integration.

Alerting

Pandas

Implement validation on pandas DataFrames.

Metadata & Data Quality

Pandera

Generate Dagster Types from Pandera dataframe schemas.

Metadata & Data Quality

Polars

Use Polars eager or lazy DataFrames as inputs and outputs in Dagster.

Metadata & Data Quality

Power BI

Monitor a Power BI workspace as assets in Dagster.

Business Intelligence

Prometheus

Integrate with Prometheus through the prometheus_client library.

Logging & Monitoring

Ray

Scale Python workloads with Ray’s distributed computing framework.

Compute

Salesforce

Query records, perform bulk operations, and sync Salesforce customer data.

Other

SDF

Put your SDF transformations to work directly from Dagster.

ETL / Reverse ETL

Secoda

Help your team understand Dagster metadata by adding context in Secoda.

Metadata & Data Quality

SFTP

High-performance secure file transfer with parallel transfers and advanced filtering.

Storage

Sigma

Monitor a Sigma organization as assets in Dagster.

Business Intelligence

Slack

Improve notifications and keep stakeholders in the loop.

Alerting

Sling

Extract and load data from popular sources to destinations with Sling.

ETL / Reverse ETL

SLURM

Bridge high-performance computing with modern data orchestration.

Compute

Snowflake

Read and write natively to Snowflake from software-defined assets.

Storage

Spark

Configure and run Spark jobs.

Compute

SSH/SFTP

Establish encrypted connections to networked resources.

Other

Tableau

Monitor a Tableau workspace as assets in Dagster.

Business Intelligence

Twilio

Integrate Twilio tasks into your data pipeline runs.

Alerting

Weights & Biases

Orchestrate MLOps pipelines and maintain machine-learning assets.

Other

Start Your Data Journey Today

Unlock the power of data orchestration with our demo or explore the open-source version.

Try Dagster+