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