码迷,mamicode.com
首页 > 其他好文 > 详细

AirFlow 任务运行异常: Task is not able to be run

时间:2018-06-26 00:48:13      阅读:1176      评论:0      收藏:0      [点我收藏+]

标签:test   使用   提示   过程   错误提示   cut   exe   后台   job   

记录一次airflow异常排查过程:

在定时任务执行一段时间后突然出现任务无法执行了,后台woker日志显示如下提示信息:

[2018-05-25 17:22:05,068] {jobs.py:2508} INFO - Task is not able to be run

查看任务对应的执行日志:

cat /home/py/airflow-home/logs/testBashOperator/print_date/2018-05-25T00:00:00/6.log

...
[2018-05-25 17:22:05,067] {models.py:1190} INFO - Dependencies not met for <TaskInstance: testBashOperator.print_date 2018-05-25 00:00:00 [success]>, 
dependency ‘Task Instance State‘ FAILED: Task is in the ‘success‘ state which is not a valid state for execution. The task must be cleared in order to be run.

根据错误提示,说明依赖任务状态失败,针对这种情况有两种解决办法:

  • 使用airflow run运行task的时候指定忽略依赖task:
airflow run -A dag_id task_id execution_date   
  • 使用命令airflow clear dag_id进行任务清理:
airflow clear -u testBashOperator

清理之后airflow运行恢复正常.

AirFlow 任务运行异常: Task is not able to be run

标签:test   使用   提示   过程   错误提示   cut   exe   后台   job   

原文地址:https://www.cnblogs.com/cord/p/9226637.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!