# HG changeset patch # User Mads Kiilerich # Date 1473115878 -7200 # Node ID f770722cdb6cd2669d0e1f46f74b897e95477fc9 # Parent 9452b5a8e06f436db32e9a20adc76c9f85b39223 celery: drop wrong use of on_failure - if it should work, it should be a method somewhere, not a local function diff -r 9452b5a8e06f -r f770722cdb6c kallithea/lib/celerylib/tasks.py --- a/kallithea/lib/celerylib/tasks.py Tue Sep 06 00:51:18 2016 +0200 +++ b/kallithea/lib/celerylib/tasks.py Tue Sep 06 00:51:18 2016 +0200 @@ -235,7 +235,7 @@ log.debug('Breaking recursive mode due to reach of recurse limit') return True except LockHeld: - log.info('LockHeld') + log.info('Task with key %s already running', lockkey) return 'Task with key %s already running' % lockkey @@ -407,10 +407,6 @@ RepoModel(DBS)._delete_filesystem_repo(repo) raise - # it's an odd fix to make celery fail task when exception occurs - def on_failure(self, *args, **kwargs): - pass - return True @@ -491,10 +487,6 @@ RepoModel(DBS)._delete_filesystem_repo(repo) raise - # it's an odd fix to make celery fail task when exception occurs - def on_failure(self, *args, **kwargs): - pass - return True