Поток воздуха использовать внешний датчик, чтобы дождаться окончания DAG - PullRequest
Новая
       6

Поток воздуха использовать внешний датчик, чтобы дождаться окончания DAG

0 голосов
/ 06 ноября 2019

Я хотел бы использовать датчик, чтобы заставить DAG ждать другого DAG перед запуском.

Я создал следующий код для этого: 

ExternalTaskSensor(
        task_id='task_that_wait_the_dag_before_starting',
        external_dag_id='dag_to_wait_it_finishes',
        dag=dag

    ) >> TaskToExecute(
        task_id='task_to_execute,
        dag=dag)

Но когда я развернул его, У меня ошибка:

Сломанный DAG: требуется аргумент ['external_task_id']

Это аргумент для внешней задачи. Дело в том, что я не хочу ждать какой-то конкретной задачи, я хочу дождаться полного перехода знака.

В документе мы можем видеть это:

Ожидаетдругая группа обеспечения доступности баз данных или задача в другой группе обеспечения доступности баз данных для выполнения для конкретной даты выполнения

Зачем нужен идентификатор external_task, если я могу просто подождать группу обеспечения доступности баз данных.

...