Files
@ 6b934c9607e7
Branch filter:
Location: kallithea/pylons_app/lib/celerylib/__init__.py - annotation
6b934c9607e7
539 B
text/x-python
Improved testing scenarios. Made test env creator
Fixed hg_model error message
some other tweeks and fixes
Models fixe for uniq email, and removed some extra not needed imports from model main module
Fixed hg_model error message
some other tweeks and fixes
Models fixe for uniq email, and removed some extra not needed imports from model main module
3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b 3fc3ce53659b | from vcs.utils.lazy import LazyProperty
import logging
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,async,*args,**kwargs):
try:
t = task.delay(*args,**kwargs)
log.info('running task %s',t.task_id)
if not async:
t.wait()
return t
except:
#pure sync version
return ResultWrapper(task(*args,**kwargs))
|