2
当我尝试扩展airflow API中提供的SubDagOperator时,airflow webserver GUI不会将其识别为SubDagOperator,从而禁用我放大该子标签。气流:如何扩展SubDagOperator?
如何扩展SubDagOperator,同时保留作为子标签放大的能力?我错过了什么吗?
当我尝试扩展airflow API中提供的SubDagOperator时,airflow webserver GUI不会将其识别为SubDagOperator,从而禁用我放大该子标签。气流:如何扩展SubDagOperator?
如何扩展SubDagOperator,同时保留作为子标签放大的能力?我错过了什么吗?
如果您将subdag定义为dag本身,则应该起作用。
气流有一个很好的例子。您还必须注意命名约定,子标签名称必须是parent_name.child_name格式。
主要DAG
的subdags https://github.com/apache/incubator-airflow/blob/master/airflow/example_dags/subdags/subdag.py
每当问问题。最好添加一个迄今为止尝试过的例子。帮助人们了解问题的症结所在。 – matt
仍然没有解决方案?我读了它的代码:https://github.com/apache/incubator-airflow/blob/9d5cc6ef5fe18055395ab671d602d70ab18dcbd2/airflow/models.py#L3450,这一行表明气流使用'SubDagOperator'来决定子标签。所以我认为不可能扩展SubDagOperator,除非我们改变气流代码或等待新版本支持。 – Freedom