Malavika S Menon
08/22/2022, 10:38 AMAnna Geller
08/22/2022, 10:46 AM@flow(description="Fail immediately if any subflow fails")
def data_warehouse_load():
staging_area()
data_mart()
data_services()
Malavika S Menon
08/22/2022, 10:49 AMAnna Geller
08/22/2022, 10:50 AMyour_subflow.submit
is on the roadmap - this will return a future and will allow you to handle state dependencies as you like
until then, this might be a workaround https://discourse.prefect.io/t/how-to-create-a-flow-run-from-deployment-orchestrator-pattern/803Malavika S Menon
08/22/2022, 10:55 AMAnna Geller
08/22/2022, 11:20 AM