如何以编程方式清除谷歌作曲家TASK

Question

我使用的是一个动态创建任务的DAG：每次我在DAG中创建新任务时，我都想清除同一DAG中的另一个任务，这可能吗？

我们没有找到任何支持清除任务的API，我们缺少什么吗？

我们正在尝试使用airflow CLI，但似乎无法清除由具体的"执行日期"，还有其他选项吗？

提前感谢

Answer 1

您可以使用airflow clearcli命令来实现这一点。

airflow clear [-h] [-t TASK_REGEX] [-s START_DATE] [-e END_DATE] [-sd SUBDIR]
[-u] [-d] [-c] [-f] [-r] [-x] [-dx]
dag_id

文件：https://airflow.apache.org/cli.html#clear

Answer 2

您可以在composer中使用此命令清除任务状态：
gcloud composer environments run <environment> --location=asia-northeast1 clear -- <DAG_ID> -c -s <dag run start date> -e <dag run end date> --upstream --downstream