如何清除气流/合成器中使用CLI的dag运行状态？ [英] How do I clear the state of a dag run with the CLI in airflow/composer?

问题描述

我想我可以使用以下命令：

I thought I could use the command:

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挂在一条消息上，例如：

the clear the state of the dag runs on 2018-05-13. For some reason it doesn't work. What happens is that the CLI hangs on a message like:

kubeconfig entry generated for <kube node name>.

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

What is the expected behavior of the command above? I would expect it to clear the dag run for the interval, but I might be doing something wrong.

推荐答案

运行<$ c Cloud Composer上的$ c> clear 要求您将 -c 参数添加到命令中，如下所示：

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

g个beta编写器环境运行< env> --location = us-central1 clear-< dag_id> -c -s 2018-05-13 -e 2018-05-14


这篇关于如何清除气流/合成器中使用CLI的dag运行状态？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！