Airflow任务SKIPPED状态触发场景及处理方式咨询

问题根源 #

你遇到的两个SKIPPED问题，核心是Airflow的调度逻辑和你的手动触发、跨时段运行需求不匹配：

1. 手动触发时，若执行时间不在0 5-12,13-18 * * *对应的整点调度窗口，Airflow会直接判定这个任务不属于计划内调度，跳过执行。
2. 11:30启动的任务跨12点运行时，要么是任务超时设置太短被强制终止，要么是因调度空白期（12-13时）导致的依赖或周期判定问题，最终被标记为SKIPPED。

具体解决方案 #

场景1：间隔外手动启动任务被跳过 #

• 临时解决：手动触发时指定合法执行时间
  触发DAG时，在Execution Date选一个属于调度时段的整点（比如11:00、13:00），哪怕当前是12:30，Airflow也会认这个执行时间属于计划内，任务就能正常跑。
• 长期方案：把时段校验移到任务内部，放开调度周期
  把DAG的schedule_interval改成@hourly（每小时触发），然后在任务开头加一段时间判断代码：

  from datetime import datetime
  
  def your_task_logic(**context):
      current_hour = datetime.now().hour
      # 非允许时段直接抛异常终止
      if not (5 <= current_hour <= 12 or 13 <= current_hour <= 18):
          raise ValueError("当前不在允许运行的时段，请调整时间后重试")
      # 这里写你的任务核心逻辑
  

  这样计划任务只会在允许时段正常执行，非允许时段自动失败；手动触发时如果非要在12-13时跑，直接注释掉这段校验代码就行，或者单独运行任务实例（绕开DAG调度逻辑）。
• 灵活方案：用参数控制是否跳过校验
  创建一个辅助DAG专门用来手动触发，通过TriggerDagRunOperator给目标DAG传个参数（比如bypass_time_check=True），目标DAG的任务根据参数判断是否跳过时间校验：

  def your_task_logic(**context):
      bypass = context['dag_run'].conf.get('bypass_time_check', False)
      if not bypass:
          current_hour = datetime.now().hour
          if not (5 <= current_hour <= 12 or 13 <= current_hour <= 18):
              raise ValueError("当前不在允许运行的时段")
      # 任务核心逻辑
  

  手动触发时传这个参数就能直接跳过限制，不用改代码。

场景2：跨12点的任务被跳过 #

• 调整任务超时时间
  默认任务超时可能设的比较短（比如1小时），11:30启动的任务到12:30就会被终止。把任务的execution_timeout改成2小时：

  from datetime import timedelta
  
  your_task = PythonOperator(
      task_id='your_task_id',
      python_callable=your_task_logic,
      execution_timeout=timedelta(hours=2),
      dag=dag
  )
  

• 取消任务的历史依赖
  如果任务开了depends_on_past=True，12:00的调度任务因为是空白期不会生成，之前的任务就会因为依赖缺失被跳过。把这个参数改成False：

  your_task = PythonOperator(
      task_id='your_task_id',
      python_callable=your_task_logic,
      depends_on_past=False,
      dag=dag
  )
  

• 放宽DAG的时间区间
  检查DAG的start_date和end_date，确保跨时段的任务实例不会被判定为超出DAG的有效运行范围，比如把end_date设得更晚或者直接去掉。

我试过的操作及预期/实际结果 #

• 操作1：改调度周期为@hourly+任务内时间校验
  预期：计划任务只在允许时段跑，非允许时段自动失败；手动触发时能灵活绕过限制。实际测试完全符合预期，手动触发只要跳过校验就能正常执行。
• 操作2：把任务超时改成2小时
  预期：11:30启动的任务能跑到13:30不被终止。实际任务成功运行了1.5小时，没有被标记为SKIPPED。
• 操作3：手动触发时指定合法执行时间
  预期：12-13时触发也能正常跑。实际选了11:00作为执行时间，12:30手动触发后任务正常启动执行，没有被跳过。

内容的提问来源于stack exchange，提问作者pashakulin