configuration out of it. To make sure that really is the case and give an early

warning, we check one of the mandatory settings.

This module must thus not be imported in global scope but must be imported on

demand in function scope.

"""

import os

import warnings

# Verify Pylons configuration has been loaded

from pylons import config

assert config['celery.imports'] == 'kallithea.lib.celerylib.tasks', 'Kallithea Celery configuration has not been loaded'

# Prepare environment to point at Kallithea Pylons loader

CELERYPYLONS_LOADER = 'kallithea.lib.celerypylons.loader.PylonsLoader'

if os.environ.get('CELERY_LOADER', CELERYPYLONS_LOADER) != CELERYPYLONS_LOADER:

    warnings.warn("'CELERY_LOADER' environment variable will be overridden by celery-pylons.")

os.environ['CELERY_LOADER'] = CELERYPYLONS_LOADER

# Import (and expose) celery, thus immediately triggering use of the custom Pylons loader

import celery.app as app

import celery.result as result

from celery.task import task

import kallithea

from kallithea.lib.paster_commands.common import BasePasterCommand

from kallithea.lib.utils import load_rcextensions

from kallithea.lib.utils2 import str2bool

__all__ = ['Command']

class Command(BasePasterCommand):

    """Start the celery worker

    Starts the celery worker that uses a paste.deploy configuration

    file.

    """

    usage = 'CONFIG_FILE [celeryd options...]'

    summary = __doc__.splitlines()[0]

    description = "".join(__doc__.splitlines()[2:])

    group_name = "Kallithea"

    parser = BasePasterCommand.standard_parser(quiet=True)

    def update_parser(self):

        from kallithea.lib import celerypylons

        for x in cmd.get_options():

            self.parser.add_option(x)

    def command(self):

        from kallithea.lib import celerypylons

        from pylons import config

        try:

            CELERY_ON = str2bool(config['app_conf'].get('use_celery'))

        except KeyError:

            CELERY_ON = False

        if not CELERY_ON:

            raise Exception('Please set use_celery = true in .ini config '

                            'file before running celeryd')

        kallithea.CELERY_ON = CELERY_ON

        load_rcextensions(config['here'])

        return cmd.run(**vars(self.options))

callback = lambda V: ('.'.join(map(str, V[:3])) + '.'.join(V[3:]))

__version__ = _get_meta_var('VERSION', _metadata, callback)

__license__ = _get_meta_var('__license__', _metadata)

__author__ = _get_meta_var('__author__', _metadata)

__url__ = _get_meta_var('__url__', _metadata)

# defines current platform

__platform__ = platform.system()

is_windows = __platform__ in ['Windows']

requirements = [

    "alembic>=0.8.0,<0.9",

    "waitress>=0.8.8,<1.0",

    "webob>=1.0.8,<=1.1.1",

    "Pylons>=1.0.0,<=1.0.2",

    "WebTest<2.0", # make the Pylons dependency pick a version that supports our WebOb version

    "Beaker==1.6.4",

    "WebHelpers==1.3",

    "formencode>=1.2.4,<=1.2.6",

    "SQLAlchemy>=1.0,<1.1",

    "Mako>=0.9.0,<=1.0.0",

    "pygments>=1.5",

    "whoosh>=2.4.0,<=2.5.7",

    "babel>=0.9.6,<=1.3",

    "python-dateutil>=1.5.0,<2.0.0",

    "markdown==2.2.1",

    "docutils>=0.8.1,<=0.11",

    "URLObject==2.3.4",

    "Routes==1.13",

    "dulwich>=0.14.1",

    "mercurial>=2.9,<4.0",

]

if sys.version_info < (2, 7):

    requirements.append("importlib==1.0.1")

    requirements.append("argparse")

if not is_windows:

    requirements.append("bcrypt>=2.0.0")

dependency_links = [

]

classifiers = [

    'Development Status :: 4 - Beta',

    'Environment :: Web Environment',

    'Framework :: Pylons',