kallithea Changeset - f770722cdb6c

Changeset - f770722cdb6c

Parent rev.

Child rev.

[Not reviewed]

default

0 1 0

Mads Kiilerich - 9 years ago 2016-09-06 00:51:18
madski@unity3d.com

celery: drop wrong use of on_failure - if it should work, it should be a method somewhere, not a local function

1 file changed with 1 insertions and 9 deletions:

kallithea/lib/celerylib/tasks.py

0 comments (0 inline, 0 general)

kallithea/lib/celerylib/tasks.py

➞

Show inline comments

@@ @@ -235,7 +235,7 @@ def get_commits_stats(repo_name, ts_min_ @@
             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 @@ def create_repo(form_data, cur_user): @@
             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 @@ def create_repo_fork(form_data, cur_user @@
             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

0 comments (0 inline, 0 general)