问题描述:在使用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
库一起工作。