Kayvan Shah
04/20/2021, 6:29 PMKayvan Shah
04/20/2021, 6:30 PMnicholas
upstream_tasks
should work for what you're thinkingKevin Kho
import prefect
from prefect import Flow, task
@task
def mytask():
return 1
with Flow('test-flow') as flow:
a = mytask()
b = mytask(upstream_tasks=[a])
flow.run()
Kayvan Shah
04/20/2021, 6:36 PMKayvan Shah
04/20/2021, 6:38 PMKevin Kho
with Flow("Harvest_Demo") as flow:
path_config = load_path_config()
x = harvest_metadata(path_config)
harvest_master_data(path_config, upstream_tasks=[x])
Kayvan Shah
04/20/2021, 6:40 PMKevin Kho
harvest_metadata
task and the harvest_master_data
task will grab the state from x even if there is no return value in this case.