Method mark_failed

core/taskqueue.py:64–70

(self, task_id, error='')

        self.save()

    def mark_failed(self, task_id, error=''):
        for t in self.tasks:
            if t.id == task_id:
                t.status = STATUS_FAILED
                t.error = error[:300]
                break
        self.save()

    def is_complete(self):
        return all(t.status in (STATUS_DONE, STATUS_SKIPPED) for t in self.tasks)