Files @ 7010af6efde5
Branch filter:

Location: kallithea/pylons_app/lib/celerylib/__init__.py

Marcin Kuzminski
Reimplemented searching for speed on large files and added paging for search results
Updated setup requirements
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))