self.rq.state = runQueueComplete
return
-
def notify_task_started(self, task):
bb.event.fire(runQueueTaskStarted(task, self.stats, self.rq), self.cfgData)
- logger.info("Running task %d of %d (ID: %s, %s)", self.stats.completed + self.stats.active + self.stats.failed + 1,
- self.stats.total,
- task,
- self.rqdata.get_user_idstring(task))
def notify_task_completed(self, task):
bb.event.fire(runQueueTaskCompleted(task, self.stats, self.rq), self.cfgData)
Called when a task has failed
Updates the state engine with the failure
"""
- logger.error("Task %s (%s) failed with exit code '%s'", task,
- self.rqdata.get_user_idstring(task), exitcode)
self.stats.taskFailed()
fnid = self.rqdata.runq_fnid[task]
self.failed_fnids.append(fnid)
- bb.event.fire(runQueueTaskFailed(task, self.stats, self.rq), self.cfgData)
+ bb.event.fire(runQueueTaskFailed(task, self.stats, exitcode, self.rq), self.cfgData)
if self.rqdata.taskData.abort:
self.rq.state = runQueueCleanUp
"""
Event notifing a task failed
"""
- def __init__(self, task, stats, rq):
+ def __init__(self, task, stats, exitcode, rq):
runQueueEvent.__init__(self, task, stats, rq)
+ self.exitcode = exitcode
self.message = "Task %s failed (%s)" % (task, self.taskstring)
class runQueueTaskCompleted(runQueueEvent):
logger.error("Nothing %sPROVIDES '%s'", r, event._item)
continue
+ if isinstance(event, bb.runqueue.runQueueTaskStarted):
+ logger.info("Running task %s of %s (ID: %s, %s)",
+ event.stats.completed + event.stats.active + event.stats.failed + 1,
+ event.stats.total, event.taskid, event.taskstring)
+ continue
+
+ if isinstance(event, bb.runqueue.runQueueTaskFailed):
+ logger.error("Task %s (%s) failed with exit code '%s'",
+ event.taskid, event.taskstring, event.exitcode)
+ continue
+
# ignore
if isinstance(event, (bb.event.BuildBase,
bb.event.StampUpdate,