Изменить статус заданий по значению переменной в потоке воздуха - PullRequest
0 голосов
/ 18 апреля 2019

Я пытаюсь манипулировать состоянием задачи (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, задача должна завершиться неудачей.

...