Я пытаюсь запустить процесс через оператора 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?