Skip to content
Snippets Groups Projects
Commit 4869ddd3 authored by Hervé  MENAGER's avatar Hervé MENAGER
Browse files

write full traceback in the job log in case of MonitorTask failure

WIP on #205
parent 3e74f667
No related branches found
No related tags found
1 merge request!13Master
from ippidb.models import Job import traceback
from celery import Task, states from celery import Task, states
from django_celery_results.models import TaskResult from django_celery_results.models import TaskResult
from ippidb.models import Job
class AlreadyExistError(Exception): class AlreadyExistError(Exception):
pass pass
...@@ -42,7 +44,7 @@ class MonitorTask(Task): ...@@ -42,7 +44,7 @@ class MonitorTask(Task):
super(MonitorTask, self).on_success(retval, task_id, args, kwargs) super(MonitorTask, self).on_success(retval, task_id, args, kwargs)
def on_failure(self, exc, task_id, args, kwargs, einfo): def on_failure(self, exc, task_id, args, kwargs, einfo):
self.write(std_err=exc) self.write(std_err=''.join(traceback.format_tb(einfo.tb)))
super(MonitorTask, self).on_failure(exc, task_id, args, kwargs, einfo) super(MonitorTask, self).on_failure(exc, task_id, args, kwargs, einfo)
def update_state(self, task_id=None, state=None, meta=None, **kwargs): def update_state(self, task_id=None, state=None, meta=None, **kwargs):
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment