Daniel Olausson
04/14/2020, 8:31 AM@solid(...)
def my_solid(context, **kwargs):
#some stuff
and then:
@pipeline
def my_pipeline():
task1 = my_solid.alias('task1')
task2 = my_solid.alias('task2')
task3 = my_solid.alias('task3')
task4 = my_solid.alias('task4')
task4(task1(), task2(), task3())
schrockn
04/14/2020, 2:46 PM