|
|
@ -101,9 +101,9 @@ class TaskMoniter { |
|
|
|
return false; |
|
|
|
return false; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
this.taskStatus[this.tasks[task_id].status] --; |
|
|
|
this.tasks[task_id].status = this.statusCode.waiting; |
|
|
|
this.tasks[task_id].status = this.statusCode.waiting; |
|
|
|
this.tasks[task_id].updated = common.getTimestampInSeconds(); |
|
|
|
this.tasks[task_id].updated = common.getTimestampInSeconds(); |
|
|
|
this.taskStatus[this.tasks[task_id].status] --; |
|
|
|
|
|
|
|
this.taskStatus[this.statusCode.waiting] ++; |
|
|
|
this.taskStatus[this.statusCode.waiting] ++; |
|
|
|
|
|
|
|
|
|
|
|
return true; |
|
|
|
return true; |
|
|
@ -133,10 +133,10 @@ class TaskMoniter { |
|
|
|
return false; |
|
|
|
return false; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
this.taskStatus[this.tasks[task_id].status] --; |
|
|
|
this.tasks[task_id].status = this.statusCode.failed; |
|
|
|
this.tasks[task_id].status = this.statusCode.failed; |
|
|
|
this.tasks[task_id].updated = common.getTimestampInSeconds(); |
|
|
|
this.tasks[task_id].updated = common.getTimestampInSeconds(); |
|
|
|
this.taskStatus[this.statusCode.failed] ++; |
|
|
|
this.taskStatus[this.statusCode.failed] ++; |
|
|
|
this.taskStatus[this.statusCode.running] --; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return true; |
|
|
|
return true; |
|
|
|
} |
|
|
|
} |
|
|
|