Jinjaが気流DAGの変数を翻訳していない

Jinja変数を変換しないAirflowインスタンスがあります。 DAGにこのコードがあります。Jinjaが気流DAGの変数を翻訳していない

print 'execution date is: ', ' {{ ds }} '

上記の変数は文字通りに表示されます。

INFO - Subtask: execution date is: {{ ds }}

Jinja2はpip（私はPython 2.7を使用しています）経由でインストールされています。 jinjaモジュールのimport文が問題なく同じDAGで処理されるため、PYTHONPATHが正しく設定されています。

from jinja2 import Environment

気流1.8.0を使用しています。

私は何かが不足していますが、私は手がかりを使い果たしています。

出典

2017-07-13 BGA

気流についてはわかりませんが、テンプレートのレンダリングは 'BashOperator'の' templated_command'で行われると思います。限り、私はあなたのコードから見ることができます、それらは印刷されたプレーンな文字列であり、彼らはjinjaによってレンダリングされるはずです。 – jgmh

ありがとう、@jgmh。気流チュートリアルの 'templated_command'は単なる変数名です。後で 'bash_command'に割り当てられます。 – BGA

固定。愚かな私;私はformat()を持っていて、ジンジャの引き継ぎを妨げていました。

"{path} {{ ds }} ".format(path="the/path/to/spark/code")

出典

2017-07-13 13:03:24 BGA

Jinjaが気流DAGの変数を翻訳していない

答えて

関連する問題