Ievgenii Martynenko
03/31/2022, 7:30 PMwith Flow("Test ETL Flow") as flow:
start_task_result = start_task()
truncate_task_result = truncate_task()
fetch_task_result = fetch_task()
update_template_result = update_template_task(variables=fetch_task_result)
merge_task_result = merge_task()
complete_task_result = complete_task()
truncate_task.set_upstream(start_task_result)
fetch_task.set_upstream(truncate_task_result)
merge_task.set_upstream(update_template_result)
complete_task.set_upstream(merge_task_result)
flow.visualize()
Kevin Kho
truncate_task.set_upstream(start_task_result)
Instead you want:
truncate_task_result.set_upstream(start_task_result)
so that the upstream is set on the instance.truncate_task.set_upstream(start_task_result)
refers to the task while truncate_task_result
is the instance of the taskIevgenii Martynenko
03/31/2022, 7:37 PMKevin Kho