如何清除气流/合成器中使用CLI的dag运行状态?

Tom*_*son 1 airflow airflow-scheduler google-cloud-composer

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

g beta composer environments run <env> --location=us-central1 clear -- <dag_id> -s 2018-05-13 -e 2018-05-14
Run Code Online (Sandbox Code Playgroud)

dag的状态明确运行于2018-05-13。由于某种原因,它不起作用。发生的情况是CLI挂在一条消息上,例如:

kubeconfig entry generated for <kube node name>.
Run Code Online (Sandbox Code Playgroud)

上面命令的预期行为是什么?我希望它能清除间隔内的dag运行,但我可能做错了。

Leo*_*Leo 5

Running clear on Cloud Composer requires you to add -c parameter to the command like so:

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

  • https://airflow.apache.org/cli.html#Named%20Arguments_repeat3 -c代表“未确认” (2认同)