dhume
06/09/2020, 6:14 PMdef hello_world():
return dagstermill.define_dagstermill_solid(
name="hello_world",
notebook_path="hello_world.ipynb",
input_defs=[InputDefinition(name="a"), InputDefinition(name="b")]
)
@pipeline
def demo_notebook_pipeline():
hello_world()
if __name__ == "__main__":
result = execute_pipeline(demo_notebook_pipeline)
assert result.success
And I included the pipeline in the pipeline_defs
for my RepositoryDefinition
but when I run dagit it does not appear as a valid pipelinemax
06/09/2020, 6:18 PMhello_world
doesn't actually execute the solid -- hello_world
is a solid factory, i.e., it returns a solidhello_world()
inside the @pipeline
decorator doesn't do anything -- you would need to do hello_world()()
hello_world = define_dagstermill_solid(...)
dhume
06/09/2020, 6:20 PMmax
06/09/2020, 6:20 PM