This section contains examples of how to use Dagster. All examples can be found on Github.

Airflow IngestCreate a pipeline from an Airflow DAGOpen
Airline DemoA comprehensive demo to showcase Dagster and Dagit capabilitiesOpen
Asset MaterializationRecord that a solid materialized an assetOpen
Conditional ExecutionConditionally execute part of a pipelineOpen
Config MappingSimplify solid config schemas with config mapping.Open
dbt IntegrationUse dagster-dbt to integrate dbt projects with DagsterOpen
Dependency DSLCreate a custom DSL for defining pipelinesOpen
Docker DeploymentExample Docker DeploymentOpen
EMR PySparkRun a PySpark solids in EMROpen
Execute Pipeline GraphQLTrigger a Dagster pipeline externally by a GraphQL clientOpen
Fan-In DependencyCreate a pipeline with a fan-in dependencyOpen
Great Expectations integrationUse Great Expectations to check data qualityOpen
HooksCreate a pipeline with hooksOpen
Multi-Location WorkspaceSetup a Dagster workspace with multiple locationsOpen
No-Data DependenciesModeling dependencies without inputs and outputsOpen
Solid and Pipeline TagsCreate a pipeline with tags and a solid with tagsOpen
Pipeline Unit TestUnit-test a pipelineOpen
PySparkRun PySpark code in solidsOpen
User in the LoopSet conditions for whether a pipeline should continue runningOpen
Dynamic Graph (Experimental)Determine graph structure at runtimeOpen
Lakehouse (Experimental)Define a computation graph in terms of the tables it producesOpen
Lakehouse w/ Two Types (Experimental)Use the Lakehouse API with multiple compute typesOpen
Memoization (Experimental)Memoizing results from previous pipeline runsOpen