master_flow.py

""" Trigger child Flows from this parent Flow """
from prefect.tasks.prefect.flow_run import FlowRunTask
from prefect import Flow


with Flow("MasterFlow") as flow:
    staging_area = FlowRunTask(flow_name='staging_area',
                               project_name="InterFlow_Dependencies",
                               wait=True)
    business_logic_layer = FlowRunTask(flow_name='business_logic_layer',
                                       project_name="InterFlow_Dependencies",
                                       wait=True)
    data_mart = FlowRunTask(flow_name='data_mart',
                            project_name="InterFlow_Dependencies",
                            wait=True)
    staging_area.set_downstream(business_logic_layer)
    business_logic_layer.set_downstream(data_mart)

if __name__ == '__main__':
    flow.register("InterFlow_Dependencies")