在Kubernete中通过BashOperator执行CLI命令

Question

我们将气流架构从Celery移到了Kubernete Executor。

当主链中的前一个命令完成时，我正在使用bash命令运行第二天:

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

但遗憾的是，我不知道如何从Kubernetes内部运行CLI命令。提前感谢您的支持。

Answer 1

解决方案是简单地使用TriggerDagRunOperator而不是使用一些bash命令。