Блог

Мы перенесли нашу архитектуру воздушного потока из Celery в Kubernete Executor.

Я использовал команду bash для запуска следующего dag, когда предыдущий в основной цепочке был завершен:

 my_task_1 = bash.BashOperator( task_id="my_task_1", dag=dag, bash_command='airflow dags trigger dag_2_id' )  

Но, к сожалению, я не могу понять, как запускать команды CLI изнутри Kubernetes. Заранее благодарю вас за вашу поддержку.

Решение состояло в том, чтобы просто использовать TriggerDagRunOperator вместо того, чтобы делать это с помощью некоторых команд bash.