Mercurial > kallithea
changeset 6168:f770722cdb6c
celery: drop wrong use of on_failure - if it should work, it should be a method somewhere, not a local function
author | Mads Kiilerich <madski@unity3d.com> |
---|---|
date | Tue, 06 Sep 2016 00:51:18 +0200 |
parents | 9452b5a8e06f |
children | 81c13cdbe91f |
files | kallithea/lib/celerylib/tasks.py |
diffstat | 1 files changed, 1 insertions(+), 9 deletions(-) [+] |
line wrap: on
line diff
--- 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