Files
@ a9e50dce3081
Branch filter:
Location: kallithea/pylons_app/lib/celerylib/__init__.py - annotation
a9e50dce3081
570 B
text/x-python
Removed config names from whoosh and celery,
celery is now configured based on the config name it's using
on celeryconfig. And whoosh uses it's own logger configured just for whoosh
Test creates a fresh whoosh index now, for more accurate checks
fixed tests for searching
celery is now configured based on the config name it's using
on celeryconfig. And whoosh uses it's own logger configured just for whoosh
Test creates a fresh whoosh index now, for more accurate checks
fixed tests for searching
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))
|