Commit 59f9a123 authored by Antoine Millet's avatar Antoine Millet
Browse files

Rollback is now a private method of jobs.

parent def7bf40
Loading
Loading
Loading
Loading
+3 −3
Original line number Diff line number Diff line
@@ -82,10 +82,10 @@ class BaseJob(dict, Thread, object):
        try:
            self.job()
        except JobCancelError as err:
            self.rollback('%s' % err)
            self._rollback('%s' % err)
        except Exception as err:
            logging.error('Error while executing job: %s, %r', err, err)
            self.rollback('%s' % err)
            self._rollback('%s' % err)

    def job(self):
        '''
@@ -108,7 +108,7 @@ class BaseJob(dict, Thread, object):
        if func is not None:
            self._wayback.append(func)

    def rollback(self, error):
    def _rollback(self, error):
        '''
        Rollback the job.
        '''