data_mart.py

from prefect import task, Flow


@task(log_stdout=True)
def data_mart_1():
    print("Executing data_mart_1")


@task(log_stdout=True)
def data_mart_2():
    print("Executing data_mart_2")


@task(log_stdout=True)
def data_mart_3():
    print("Executing data_mart_3")


with Flow("data_mart") as flow:
    etl_1 = data_mart_1()
    etl_2 = data_mart_2()
    etl_3 = data_mart_3()
    etl_1.set_downstream(etl_2)
    etl_2.set_downstream(etl_3)

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