diff --git a/swh/core/scheduling.py b/swh/core/scheduling.py index c3e7e1a..16f307f 100644 --- a/swh/core/scheduling.py +++ b/swh/core/scheduling.py @@ -1,23 +1,31 @@ # Copyright (C) 2015 The Software Heritage developers # See the AUTHORS file at the top-level directory of this distribution # License: GNU General Public License version 3, or any later version # See top-level LICENSE file for more information import celery +from celery.utils.log import get_task_logger class Task(celery.Task): """a schedulable task (abstract class) Sub-classes must implement the run() method Current implementation is based on Celery. See http://docs.celeryproject.org/en/latest/reference/celery.app.task.html for how to use tasks once instantiated """ abstract = True def run(self, *args, **kwargs): raise NotImplementedError('tasks must implement the run() method') + + @property + def log(self): + if not hasattr(self, '__log'): + self.__log = get_task_logger('%s.%s' % + (__name__, self.__class__.__name__)) + return self.__log