当Airflow任务卡在计划状态下时,可以尝试以下解决方法:
from datetime import timedelta
from airflow import DAG
default_args = {
'owner': 'airflow',
'start_date': airflow.utils.dates.days_ago(1),
'retries': 1,
'retry_delay': timedelta(minutes=5),
}
dag = DAG(
dag_id='your_dag_id',
default_args=default_args,
schedule_interval='0 0 * * *', # 每天午夜运行
)
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
default_args = {
'owner': 'airflow',
'start_date': airflow.utils.dates.days_ago(1),
'retries': 1,
'retry_delay': timedelta(minutes=5),
}
dag = DAG(
dag_id='your_dag_id',
default_args=default_args,
schedule_interval='0 0 * * *', # 每天午夜运行
)
task1 = BashOperator(
task_id='task1',
bash_command='echo "Task 1"',
dag=dag,
)
task2 = BashOperator(
task_id='task2',
bash_command='echo "Task 2"',
dag=dag,
)
task2.set_upstream(task1) # 设置task2的前置任务为task1
airflow scheduler
airflow webserver -p 8080
如果尝试上述解决方法后仍然无法解决问题,可以检查Airflow日志以获取更多详细信息,并尝试根据日志中的错误消息进行调试。