Измените время 'next_execution_date' на потоке воздуха в 'BashOperator' - PullRequest
Новая
       29

Измените время 'next_execution_date' на потоке воздуха в 'BashOperator'

1 голос
/ 30 января 2020

Я пытаюсь запустить процесс через оператора Bash. 

bash =BashOperator(
        task_id='Trigger some dag',
        bash_command='airflow trigger_dag -e "{{ next_execution_date }}" some_dag_id',
        dag=dag,
    )

Я знаю, что Airflow использует маятник для управления временем, поэтому, просмотрев документацию, я попробовал '.set 'method 

bash =BashOperator(
        task_id='Trigger some dag',
        bash_command='airflow trigger_dag -e "{{ next_execution_date.set(hour=someHour) }}" some_dag_id',
        dag=dag,
    )

, но я получаю сообщение об ошибке 'pendulum.pendulum.Pendulum object' has no attribute 'set'.

Я не смог найти дополнительную документацию.

Как я могу изменить час следующей_execution_date?

1 Ответ

0 голосов
/ 02 февраля 2020

Попробуйте это (не проверено): 

bash =BashOperator(
        task_id='Trigger some dag',
        bash_command='airflow trigger_dag -e "{{ macros.ds_add(next_execution_date, 1)}}" some_dag_id',
        dag=dag,
    )

Почему вы запускаете dag из DAG?

...