気流：SubDagOperatorを拡張する方法？

エアフローAPIで提供されているSubDagOperatorを拡張しようとすると、エアフローWebサーバのGUIがSubDagOperatorとして認識しないため、サブダグをズームインできなくなります。気流：SubDagOperatorを拡張する方法？

SubDagOperatorをサブダグとしてズームインする機能を維持しながら、どのように拡張できますか？何か不足していますか？

出典

2017-02-15 subba

質問をするたびに。これまでに試したことの例を追加するのが常にベストです。問題がどこにあるかを人々が理解できるようにします。 – matt

まだ解決策はありませんか？私はそのコードを読んでいます：https://github.com/apache/incubator-airflow/blob/9d5cc6ef5fe18055395ab671d602d70ab18dcbd2/airflow/models.py#L3450、この行は気流が 'SubDagOperator'を使ってサブダグを決定することを示しています。だから私は気流コードを変更したり、新しいバージョンがこれをサポートするのを待っていない限り、SubDagOperatorを拡張することはできないと思います。 – Freedom

サブダグをダグ自体として定義すると、これはうまくいくはずです。

気流からの良い例があります。命名規則にも注意する必要があります。サブデグ名はparent_name.child_name形式でなければなりません。

メインDAG

https://github.com/apache/incubator-airflow/blob/master/airflow/example_dags/example_subdag_operator.py

subdags https://github.com/apache/incubator-airflow/blob/master/airflow/example_dags/subdags/subdag.py

出典

2017-02-23 12:41:15

気流：SubDagOperatorを拡張する方法？

答えて

関連する問題