我们正在通过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个选项:backfill
、scheduled
&manual
。该值由"Airflow"本身设定。