运行 Google Cloud Composer 中的气流 cli

Run airflow cli in Google Cloud Composer

我尝试在 Google Cloud Composer 环境中 运行 气流测试 cli,但它不起作用。

基本上,我想运行 airflow test 在airflow环境下测试一个任务。我正在按照此处的说明进行操作:https://cloud.google.com/composer/docs/how-to/accessing/airflow-cli

这是命令我运行:

gcloud beta composer environments run ENVIRONMENT_NAME test MY_DAG FIRST_TASK 2018-05-05

输出:

ERROR: (gcloud.beta.composer.environments.run) unrecognized arguments:

您需要在 Airflow 子命令 ("test") 及其参数之间包含两个连字符。连字符指示 gcloud 忽略后面的参数并将它们传递给 Airflow 子命令。

gcloud beta composer environments run ENVIRONMENT_NAME test -- MY_DAG FIRST_TASK 2018-05-05

参考:https://cloud.google.com/sdk/gcloud/reference/beta/composer/environments/run