Как запустить скрипт воздушного потока после завершения предыдущего скрипта воздушного потока? - PullRequest
0 голосов
/ 08 ноября 2018

Я знаю, что, например, если у нас есть несколько файлов sql в папке данных, мы можем установить приоритеты, такие как script1 >> script2 в конце.Однако можем ли мы установить приоритеты других сценариев воздушного потока, которые на самом деле находятся в папке dag?

1 Ответ

0 голосов
/ 09 ноября 2018

Это не приоритеты, а порядок исполнения. Если вы хотите, чтобы определенная группа доступности баз данных выполнялась первой, просто установите для нее более раннее время выполнения, чем для других групп доступности базы данных.

script1 >> script2 означает, что скрипт1 выполняется первым, а только потом скрипт2.

Можно попытаться принудительно принудительно установить приоритет, назначив конкретную группу обеспечения доступности баз данных для именованной очереди , где она является единственной группой обеспечения доступности баз данных, которая выполняется в этой именованной очереди. Кроме этого не существует явного способа иметь приоритет для целых групп доступности баз данных.

Для оператора внутри DAG вы можете использовать параметр priority_weight в BaseOperator.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...