#bash #kubernetes #command-line-interface #airflow
Вопрос:
Мы перенесли нашу архитектуру воздушного потока из 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. Заранее благодарю вас за вашу поддержку.
Комментарии:
1. Что именно вы пытались сделать? У вас есть какие-то ошибки / журналы?
Ответ №1:
Решение состояло в том, чтобы просто использовать TriggerDagRunOperator вместо того, чтобы делать это с помощью некоторых команд bash.