Rubén Lopez Lozoya
02/26/2021, 2:49 PMalex
02/26/2021, 3:37 PM# can specify definition name by argument
@composite_solid(name='food_extract')
def extract():
pass
# can name invocations to make pipeline appear cleaner
@pipeline
def food_etl():
e = food_extract.alias('extract')()
t = food_transform.alias('transform')(e)
l = food_load.alias('load')(t)
# unique names *per repository* so could also split in to two repos
@repository
def food():
[food.etl_pipeline]
@repository
def drinks():
[drinks.etl_pipeline]
Rubén Lopez Lozoya
02/26/2021, 4:07 PM