У меня есть следующий DAG с несколькими простыми задачами:
hour_list = [“0:00”, “1:00", “2:00”]
for hour in hour_list:
bash_op = BashOperator(
task_id=‘task1_op1’+hour
,bash_command=“date”
,dag=dag
)
py_op = PythonOperator(
task_id='doit’+hour,
provide_context=True,
python_callable=python_method,
dag=dag)
py_op.set_upstream(bash_op)
Теперь я вижу, что dag выполняется параллельно для всех часов с 0:00 до 2:00.Это ожидаемое поведение.Но я хочу запустить дагов один час за другим, так как выполнение второго часа зависит от первого часа.Я не уверен, что любое изменение в настройках могло бы помочь здесь.Я ценю ваши мысли.спасибо.