Skip to content

Instantly share code, notes, and snippets.

Last active May 20, 2020 21:38
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
Star You must be signed in to star a gist
What would you like to do?
from dagster import pipeline, solid, RepositoryDefinition, InputDefinition, execute_pipeline, DagsterInstance
@solid(input_defs=[InputDefinition("number", int)])
def process(context, number):"Number: {}".format(number))
def root(context):
numbers = [1, 2, 3, 4, 5]
for number in numbers:
execute_pipeline(process_number, instance=DagsterInstance.get(), environment_dict={
'solids': {
'my_solid': {
'inputs': {
'number': number
def root_pipeline():
def process_number():
def define_repository():
return RepositoryDefinition("my_repository", pipeline_defs=[root_pipeline, process_number])
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment