Mercurial > kallithea

changeset 6168:f770722cdb6c

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
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