Files
@ 7afbc45aab28
Branch filter:
Location: kallithea/pylons_app/lib/celerylib/__init__.py - annotation
7afbc45aab28
570 B
text/x-python
added caching queries to hg-app
3fc3ce53659b 3fc3ce53659b a3d9d24acbec a3d9d24acbec a3d9d24acbec 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b a3d9d24acbec 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b a3d9d24acbec 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b | from vcs.utils.lazy import LazyProperty
import logging
import os
import sys
import traceback
log = logging.getLogger(__name__)
class ResultWrapper(object):
def __init__(self, task):
self.task = task
@LazyProperty
def result(self):
return self.task
def run_task(task,*args,**kwargs):
try:
t = task.delay(*args,**kwargs)
log.info('running task %s',t.task_id)
return t
except:
log.error(traceback.format_exc())
#pure sync version
return ResultWrapper(task(*args,**kwargs))
|