как расширить переменные Jinja в воздушном потоке? - PullRequest
Новая
       21

как расширить переменные Jinja в воздушном потоке?

0 голосов
/ 07 мая 2020

Я пытаюсь создать новую переменную jinja, чтобы использовать {{ts}} с часовым поясом, но не знаю, что делать дальше.
в настоящее время работает: 

echoTask = BashOperator(
    task_id="echoTask",
    bash_command=(
        "echo {{ execution_date.astimezone('Europe/Amsterdam')}}" # correcttime
    ),
    dag=dag,
)

Но это не идеально, потому что у меня около 10 дагов и я использую ts во многих местах для создания папок с меткой времени et c.

Есть ли способ расширить переменные jinja, например, { {ts_ams}}

Я использую airflow 1.10.10, а airflow.cfg уже имеет значение default_timezone = Europe / Amsterdam .

Спасибо

...