2017-07-13 31 views
0

我有一個Airflow實例不會轉換Jinja變量。我在我的DAG中有這個代碼。Jinja沒有在氣流DAG中轉換變量

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

上述變量是字面打印的。

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

Jinja2通過pip安裝(我使用Python 2.7)。 PYTHONPATH設置正確,因爲來自jinja模塊的import語句在同一個DAG中處理沒有問題。

from jinja2 import Environment 

我正在使用airflow 1.8.0。

我錯過了一些東西,但我沒有線索。

+0

不知道氣流,但我想模板的渲染是在'BashOperator'的'templated_command'中完成的。據我的代碼可以看到,這些是純字符串打印,他們不應該由忍者渲染。 – jgmh

+0

謝謝,@ jgmh。 Airflow教程中的'templated_command'只是一個變量名稱。它稍後分配給'bash_command'。 – BGA

回答

0

固定。愚蠢的我;我有一個format(),阻止Jinja接管。

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