此问题可能是由于Airflow的时间设置或DAG中的schedule_interval引起的。请尝试更新DAG并确保schedule_interval的设置正确。另外,也可以尝试更改airflow.cfg文件中的“default_timezone”选项,以确保正确的时区设置。
代码示例:
在您的DAG文件中,确保schedule_interval设置正确(例如1天或7天):
from datetime import datetime, timedelta
from airflow import DAG
from airflow.operators.python_operator import PythonOperator
default_args = {
'owner': 'airflow',
'depends_on_past': False,
'start_date': datetime(2019, 1, 1),
'email_on_failure': False,
'email_on_retry': False,
'retries': 0,
}
dag = DAG(
'example_dag',
default_args=default_args,
schedule_interval=timedelta(days=1),
)
def my_python_function():
# Your Python code here
pass
task = PythonOperator(
task_id='example_task',
python_callable=my_python_function,
dag=dag,
)
然后,更新您的airflow.cfg文件,确保“default_timezone”设置正确:
[core]
default_timezone = Asia/Shanghai