Files
@ 7010af6efde5
Branch filter:
Location: kallithea/pylons_app/lib/celerylib/__init__.py - annotation
7010af6efde5
570 B
text/x-python
Reimplemented searching for speed on large files and added paging for search results
Updated setup requirements
Updated setup requirements
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))
|