问题描述:在使用Airflow的自定义日期时,与datetime库一起正常工作,但与pendulum库一起不正常。
解决方法:
pendulum和pendulum-1.4.4以上版本的apache-airflow。[core]
...
default_timezone = UTC
pendulum库的日期函数时,确保将其转换为datetime对象。例如:import pendulum
from datetime import datetime
def my_custom_date():
pendulum_date = pendulum.now().subtract(days=1)
date = datetime(pendulum_date.year, pendulum_date.month, pendulum_date.day)
return date
start_date参数。例如:dag = DAG(
'my_custom_dag',
default_args=default_args,
start_date=my_custom_date(),
...
)
通过执行以上步骤,您将能够在Airflow中正常使用自定义日期,并与pendulum库一起工作。