Макросы выполнения воздушного потока возвращают неправильное значение - PullRequest
Новая
       5

Макросы выполнения воздушного потока возвращают неправильное значение

0 голосов
/ 07 октября 2019

Я пытаюсь получить prev_execution_date, используя макросы Airflow, но возвращается только текущая дата выполнения, независимо от того, какой макрос я называю

Это код задачи, который я использую 

get_last_run = BashOperator(
    task_id='get_last_run',
    xcom_push=True,
    bash_command='echo "{{ execution_date }}, {{ prev_execution_date }}, {{next_execution_date}}"',
    dag=dag,
)

И это возвращаемые значения (точно такие же):

[2019-10-07 16:26:41,781] {{bash_operator.py:123}} INFO - 2019-10-07T16:23:44.864787+00:00, 2019-10-07T16:23:44.864787+00:00, 2019-10-07T16:23:44.864787+00:00

Кто-нибудь знает, что происходит и почему макросы не работают должным образом?

...