from prefect import flow, task
from prefect import get_run_logger

@task
def huge_data(i):

    return "Return Huge data!"

@flow(name="test_flow")
def test_flow():
    for i in range(5):
        huge_data(i)

if __name__ == "__main__":
    test_flow()