我以为我可以使用命令：
g beta composer environments run <env> --location=us-central1 clear -- <dag_id> -s 2018-05-13 -e 2018-05-14
清除 dag 的状态在 2018-05-13 运行。由于某种原因，它不起作用。发生的情况是 CLI 挂起如下消息：
kubeconfig entry generated for <kube node name>.
上述命令的预期行为是什么？我希望它能够清除间隔内的 dag 运行，但我可能做错了什么。
【问题讨论】：
标签： airflow airflow-scheduler google-cloud-composer
在 Cloud Composer 上运行 clear 需要您将 -c 参数添加到命令中，如下所示：
g beta composer environments run <env> --location=us-central1 clear -- <dag_id> -c -s 2018-05-13 -e 2018-05-14
【讨论】：
-c，命令会提示“你确定吗？（是/否）：”而不可见。
您编写的命令的行为与在本地安装上运行 airflow clear 相同。也许命令只是运行缓慢？您是否能够观察到 Airflow Web UI 中显示的任务实例的任何变化？
【讨论】：
你可以使用：
gcloud composer environments run instance-id --location us-central clear -- -s 2018-05-13 -e 2018-05-14 -dx DagID
-dx 将找到与您的 dag 名称相似的所有 dag， -c 将运行命令而无需等待您的确认。
【讨论】：