airflow - 気流は複数の同時一般的なタスクを開始します

Question

クラウド コンポーザーでいくつかのタスクを同時に取得しようとしています。

arr = {}
for i in xrange(3):
    print("i: " + str(i))
    command_formatted = command_template.format(str(i))
    create_training_instance = bash_operator.BashOperator(
        task_id='create_training_instance',
        bash_command=command_formatted)
    arr[i] = create_training_instance
    start_training.set_downstream(arr[i])  

次のエラーが発生します。

壊れた DAG: [/home/airflow/gcs/dags/scale_simple.py] Dependency 、create_training_instance は既に登録されています