Mercurial > kallithea

changeset 558:14559eb34003

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
more error catching on celery run_task
author Marcin Kuzminski <marcin@python-works.com>
date Thu, 07 Oct 2010 19:24:03 +0200
parents 29ec9ddbe258
children bc4633a41967
files rhodecode/lib/celerylib/__init__.py
diffstat 1 files changed, 11 insertions(+), 7 deletions(-) [+]
line wrap: on
line diff
--- a/rhodecode/lib/celerylib/__init__.py	Thu Oct 07 18:30:50 2010 +0200
+++ b/rhodecode/lib/celerylib/__init__.py	Thu Oct 07 19:24:03 2010 +0200
@@ -6,6 +6,7 @@
 import sys
 import traceback
 from hashlib import md5
+import socket
 log = logging.getLogger(__name__)
 
 class ResultWrapper(object):
@@ -21,14 +22,17 @@
         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):