Skip to content

Instantly share code, notes, and snippets.

@schrockn
Last active October 9, 2019 03:32
Show Gist options
  • Save schrockn/a8ad9dfa97fd97022384d8a37b1363ed to your computer and use it in GitHub Desktop.
Save schrockn/a8ad9dfa97fd97022384d8a37b1363ed to your computer and use it in GitHub Desktop.
from dagster import solid, pipeline, RepositoryDefinition
@solid
def hello_world_solid(context):
context.log.info('Hello, World!')
@pipeline
def hello_world_pipeline():
hello_world_solid() # DSL for building dependency graph
def define_hello_world_repo():
return RepositoryDefinition(
name='hello_world_repo',
pipeline_defs=[hello_world_pipeline]
)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment