氣流任務引用多個先前的任務？

Question

有沒有辦法讓我有一個任務需要完成多個上游任務，這些任務仍然能夠獨立完成？

• download_fcr - >process_fcr - >load_fcr
• download_survey - >process_survey - >load_survey

create_dashboard應要求load_fcr a nd load_survey成功完成。

我不想強迫'調查'任務鏈中的任何內容要求'fcr'任務鏈中的任何內容完成。我希望他們能夠並行處理，即使失敗也能完成。但是，儀表板任務需要在啓動前完成加載到數據庫。

fcr *-->*-->* 
      \ 
       ---> create_dashboard 
       /
survey *-->*-->* 

Answer 1

download_fcr.set_downstream(process_fcr) 
process_fcr.set_downstream(load_fcr) 

download_survey.set_downstream(process_survey) 
process_survey.set_downstream(load_survey) 

load_survey.set_downstream(create_dashboard) 
load_fcr.set_downstream(create_dashboard)