如何在Airflow的BashOperator中修改next_execution_date的时间？

你遇到的问题核心在于：Pendulum的日期时间对象是不可变类型，它并没有提供set()方法来直接修改属性——这和部分其他日期处理库的用法存在差异。要调整Pendulum对象的时间属性，正确的方式是使用replace()方法，它会返回一个修改后的新Pendulum实例，而非改动原对象。

修正后的代码示例 #

把你的BashOperator代码调整为如下形式即可：

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

关键细节说明 #

• replace(hour=someHour)：这是Pendulum官方推荐的修改时间属性的方式，你还可以同时修改多个属性，比如replace(hour=10, minute=30, second=0)来一次性调整小时、分钟和秒数。
• .isoformat()：确保输出的日期格式符合Airflow trigger_dag命令对-e参数的格式要求，避免因格式不匹配导致的执行错误。如果你的Airflow版本对日期格式有特定要求，也可以用strftime()自定义格式，比如strftime('%Y-%m-%dT%H:%M:%S')。

另外需要注意，someHour需要是整数类型（比如8、16这类数值），如果是变量的话，要确保它在模板渲染时能被正确解析为合法的小时值（0-23之间）。

内容的提问来源于stack exchange，提问作者Matipedia