aboutsummaryrefslogtreecommitdiff
path: root/rhodecode/lib/celerylib/__init__.py
diff options
context:
space:
mode:
Diffstat (limited to 'rhodecode/lib/celerylib/__init__.py')
-rw-r--r--rhodecode/lib/celerylib/__init__.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/rhodecode/lib/celerylib/__init__.py b/rhodecode/lib/celerylib/__init__.py
index 215e5bd7..b9346fe1 100644
--- a/rhodecode/lib/celerylib/__init__.py
+++ b/rhodecode/lib/celerylib/__init__.py
@@ -62,7 +62,7 @@ def run_task(task, *args, **kwargs):
if CELERY_ON:
try:
t = task.apply_async(args=args, kwargs=kwargs)
- log.info('running task %s:%s', t.task_id, task)
+ log.info('running task %s:%s' % (t.task_id, task))
return t
except socket.error, e:
@@ -75,7 +75,7 @@ def run_task(task, *args, **kwargs):
except Exception, e:
log.error(traceback.format_exc())
- log.debug('executing task %s in sync mode', task)
+ log.debug('executing task %s in sync mode' % task)
return ResultWrapper(task(*args, **kwargs))
@@ -95,7 +95,7 @@ def locked_task(func):
lockkey = __get_lockkey(func, *fargs, **fkwargs)
lockkey_path = config['here']
- log.info('running task with lockkey %s', lockkey)
+ log.info('running task with lockkey %s' % lockkey)
try:
l = DaemonLock(file_=jn(lockkey_path, lockkey))
ret = func(*fargs, **fkwargs)