python-3.x - 在“BashOperator”中更改 Airflow 上“next_execution_date”的时间

Question

我正在尝试通过 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 的时间？

Answer 1

试试这个（未经测试）：

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？