Mercurial > kallithea
view celeryconfig.py @ 538:16ba57d8fe23 rhodecode-0.0.0.8.5
version bump
author | Marcin Kuzminski <marcin@python-works.com> |
---|---|
date | Sun, 03 Oct 2010 02:24:38 +0200 |
parents | 72778dda34cf |
children | 1e757ac98988 |
line wrap: on
line source
# List of modules to import when celery starts. import sys import os import ConfigParser root = os.getcwd() PYLONS_CONFIG_NAME = 'production.ini' sys.path.append(root) config = ConfigParser.ConfigParser({'here':root}) config.read('%s/%s' % (root, PYLONS_CONFIG_NAME)) PYLONS_CONFIG = config CELERY_IMPORTS = ("pylons_app.lib.celerylib.tasks",) ## Result store settings. CELERY_RESULT_BACKEND = "database" CELERY_RESULT_DBURI = dict(config.items('app:main'))['sqlalchemy.db1.url'] CELERY_RESULT_SERIALIZER = 'json' BROKER_CONNECTION_MAX_RETRIES = 30 ## Broker settings. BROKER_HOST = "localhost" BROKER_PORT = 5672 BROKER_VHOST = "rabbitmqhost" BROKER_USER = "rabbitmq" BROKER_PASSWORD = "qweqwe" ## Worker settings ## If you're doing mostly I/O you can have more processes, ## but if mostly spending CPU, try to keep it close to the ## number of CPUs on your machine. If not set, the number of CPUs/cores ## available will be used. CELERYD_CONCURRENCY = 2 # CELERYD_LOG_FILE = "celeryd.log" CELERYD_LOG_LEVEL = "DEBUG" CELERYD_MAX_TASKS_PER_CHILD = 3 #Tasks will never be sent to the queue, but executed locally instead. CELERY_ALWAYS_EAGER = False if PYLONS_CONFIG_NAME == 'test.ini': #auto eager for tests CELERY_ALWAYS_EAGER = True #=============================================================================== # EMAIL SETTINGS #=============================================================================== pylons_email_config = dict(config.items('DEFAULT')) CELERY_SEND_TASK_ERROR_EMAILS = True #List of (name, email_address) tuples for the admins that should receive error e-mails. ADMINS = [('Administrator', pylons_email_config.get('email_to'))] #The e-mail address this worker sends e-mails from. Default is "celery@localhost". SERVER_EMAIL = pylons_email_config.get('error_email_from') #The mail server to use. Default is "localhost". MAIL_HOST = pylons_email_config.get('smtp_server') #Username (if required) to log on to the mail server with. MAIL_HOST_USER = pylons_email_config.get('smtp_username') #Password (if required) to log on to the mail server with. MAIL_HOST_PASSWORD = pylons_email_config.get('smtp_password') MAIL_PORT = pylons_email_config.get('smtp_port') #=============================================================================== # INSTRUCTIONS FOR RABBITMQ #=============================================================================== # rabbitmqctl add_user rabbitmq qweqwe # rabbitmqctl add_vhost rabbitmqhost # rabbitmqctl set_permissions -p rabbitmqhost rabbitmq ".*" ".*" ".*"