Я пытаюсь манипулировать состоянием задачи (PythonOperator) на основе выходных данных.Файл dag имеет следующую структуру:
def task1():
x = datetime.datetime.today().weekday()
task1 = PythonOperator(
task_id='task1',
python_callable=task_1,
dag=log_dag
)
task2 = PythonOperator(
task_id='task2',
python_callable=task_2,
dag=log_dag
)
task1.set_downstream(task2)
Теперь, если значение x меньше 4, задача должна завершиться неудачей.