Изменить время next_execution_date в Airflow в BashOperator

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

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

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

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'.

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

Как я могу изменить час next_execution_date?


python-3.x airflow pendulum
person Matipedia    schedule 30.01.2020    source источник

Ответы (1)


arrow_upward
0
arrow_downward

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

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?

person Simon D    schedule 02.02.2020