Chohang Ng
06/03/2021, 1:57 AMChris White
06/03/2021, 2:11 AMflow.visualize()
so you can see your task graph. In this case, you are creating 2 copies of Flow 1:
flow_1_flow().set_upstream(flow_2_flow()) # <--- here
step_2 = flow_4_flow(upstream_tasks = [flow_1_flow(),flow_3]) # <--- and here
I can’t explain why you’re only seeing flow 1 and 2 though, you should still see all 5 flows execute based on the code you’e provided hereChohang Ng
06/03/2021, 3:18 PM