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

@@ @@ -232,13 +232,13 @@ def get_commits_stats(repo_name, ts_min_ @@
             run_task(get_commits_stats, repo_name, ts_min_y, ts_max_y,
                      recurse_limit)
         if recurse_limit <= 0:
             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
 @task(ignore_result=True)
 @dbsession
 def send_email(recipients, subject, body='', html_body='', headers=None, author=None):
@@ @@ -404,16 +404,12 @@ def create_repo(form_data, cur_user): @@
         if repo:
             Repository.delete(repo.repo_id)
             DBS.commit()
             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
 @task(ignore_result=False)
 @dbsession
 def create_repo_fork(form_data, cur_user):
@@ @@ -488,16 +484,12 @@ def create_repo_fork(form_data, cur_user @@
         if repo:
             Repository.delete(repo.repo_id)
             DBS.commit()
             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
 def __get_codes_stats(repo_name):
     from kallithea.config.conf import LANGUAGES_EXTENSIONS_MAP
     repo = Repository.get_by_repo_name(repo_name).scm_instance

0 comments (0 inline, 0 general)