如何更改通过Airflow的REST API触发的DAG执行的运行ID



我们正在通过Airflow的REST接口触发Google Cloud Composer中的DAG
https://airflow.apache.org/docs/apache-airflow/stable/deprecated-rest-api-ref.html

我们可以看到,以这种方式触发的DAG会获得前缀为manual__的Run ID,例如:

Run Id
manual__2021-06-25T05.52.31.103391+00.00

当我们从云函数触发这些DAG时,我们希望将这些执行与手动执行的DAG(从UI触发(或自动调度的执行(由cron/调度标准触发(区分开来。

问题:是否可以标记通过除manual__之外的REST API触发的执行?

旁注:目前我们正在使用气流1.x的Composer,但我们计划在Composer支持后尽快更改为气流2.x。

不能更改。

Airflow具有DagRunType的枚举,具有3个选项:backfillscheduled&manual。该值由"Airflow"本身设定。

最新更新