Charles Leung
04/28/2023, 5:01 PMwait_for
command when invoking a function to get the dependency arrows but I'm not seeing anything. Code snippet is below, along with UI output. Any help would be appreciated. Thanks!
from prefect import flow, task
@task
def task_1():
pass
@task
def task_2():
pass
@task
def task_3():
pass
@flow
def my_flow():
x = task_1()
# task 2 will wait for task_1 to complete
y = task_2(wait_for=[x])
task_3(wait_for=[y])
if __name__ == "__main__":
my_flow()