Kimera Joseph
11/19/2022, 5:58 AMAnna Geller
11/19/2022, 3:18 PMfrom prefect import flow, task
# import function subflow from my_subflow.py file
from subflow import my_subflow
@task(name="Print Hello")
def print_hello(name):
msg = f"Hello {name}!"
print(msg)
return msg
@flow(name="Hello Flow")
def hello_world(name="world"):
message = print_hello(name)
my_subflow(message)
if __name__ == "__main__":
hello_world()
Kimera Joseph
11/20/2022, 12:23 PM