这通常是由于Airflow的默认时间区域设置不正确导致的。可以在dag文件中添加如下代码来解决这个问题:
from airflow.utils import timezone
from datetime import timedelta
default_args = {
'start_date': timezone.utcnow() - timedelta(days=7),
}
这将使新dag的默认开始日期设置为当前UTC时间减去7天,从而避免了调度程序延迟一周的问题。
上一篇:Airflow-DAG完整性检测-sqlalchemy.exc.OperationalError:(sqlite3.OperationalError)nosuchtable:variable
下一篇:Airflow-Docker:PermissionError:[Errno13]Permissiondenied:'<projectdirectory>'