master_flow_with_schedule.py

from prefect.tasks.prefect.flow_run import FlowRunTask
from prefect import Flow
from prefect.schedules import Schedule
from prefect.schedules.clocks import CronClock

schedule_parent_flow = Schedule(clocks=[CronClock("0 2 * * *")])


with Flow("MasterFlow", schedule=schedule_parent_flow) 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")