2017-03-27 8 views
1

タスクを独立して完了できる複数のアップストリームタスクの完了を要求する方法はありますか?気流タスクは複数の以前のタスクを参照しますか?

  • 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 *-->*-->* 

答えて

2
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) 
+0

私の代わりに、すべての依存関係を定義するために、上流使用することはできますか? process_fcr.set_upstream(download_fcr) –

関連する問題