kallithea Changeset - 14559eb34003

Changeset - 14559eb34003

Parent rev.

Child rev.

[Not reviewed]

default

0 1 0

Marcin Kuzminski - 15 years ago 2010-10-07 19:24:03
marcin@python-works.com

more error catching on celery run_task

1 file changed with 11 insertions and 7 deletions:

rhodecode/lib/celerylib/__init__.py

0 comments (0 inline, 0 general)

rhodecode/lib/celerylib/__init__.py

➞

Show inline comments

@@ @@ -6,6 +6,7 @@ import os @@
 import sys
 import traceback
 from hashlib import md5
 import socket
 log = logging.getLogger(__name__)
 class ResultWrapper(object):
@@ @@ -21,14 +22,17 @@ def run_task(task, *args, **kwargs): @@
         t = task.delay(*args, **kwargs)
         log.info('running task %s', t.task_id)
         return t
     except socket.error, e:
         if  e.errno == 111:
             log.debug('Unable to connect to celeryd. Sync execution')
         else:
             log.error(traceback.format_exc())
     except KeyError, e:
             log.debug('Unable to connect to celeryd. Sync execution')
     except Exception, e:
         print e
         if e.errno == 111:
             log.debug('Unnable to connect. Sync execution')
         else:
             log.error(traceback.format_exc())
         #pure sync version
         return ResultWrapper(task(*args, **kwargs))
         log.error(traceback.format_exc())
     return ResultWrapper(task(*args, **kwargs))
 def locked_task(func):

0 comments (0 inline, 0 general)