2

我以为我可以使用以下命令:

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 运行,但我可能做错了什么。

4

3 回答 3

7

clear在 Cloud Composer 上运行需要您向-c命令中添加参数,如下所示:

g beta composer environments run <env> --location=us-central1 clear -- <dag_id> -c -s 2018-05-13 -e 2018-05-14

于 2019-04-30T08:51:08.803 回答
1

airflow clear您编写的命令的行为与在本地安装上运行相同。也许命令只是运行缓慢?您是否能够观察到 Airflow Web UI 中显示的任务实例的任何变化?

于 2018-06-01T23:02:22.650 回答
1

您可以使用:

gcloud composer environments run instance-id --location us-central clear -- -s 2018-05-13 -e 2018-05-14 -dx DagID

其中-dx将查找与您的 dag 名称相似的所有 dag,而-c将运行该命令而无需等待您的确认。

于 2019-11-25T11:47:27.990 回答