在 Kubernetes 中从 Bash Operator 运行 CLI 命令答案

【问题标题】：Run CLI command from BashOperator in Kubernete在 Kubernetes 中从 Bash Operator 运行 CLI 命令
【发布时间】：2021-10-17 14:41:54
【问题描述】：

我们将气流架构从 Celery 迁移到 Kubernetes Executor。

当主链中的前一个 dag 完成时，我正在使用 bash 命令运行下一个 dag：

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

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

【问题讨论】：

【解决方案1】：

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

【讨论】：