upstream/kallithea Files · celeryconfig.py

refactoring for new vcs implementation...

refactoring for new vcs implementation renamed all ._short and .raw_id into .short_id updated dependency for vcs to 0.1.6

marcink - - Load All Authors

File last commit:

r512:d945c95b default


                r512:d945c95b

default

Download file

             celeryconfig.py
        
                    74 lines
            
             | 2.4 KiB
            
                | text/x-python
            
             |
                PythonLexer
            
             / celeryconfig.py
          
                    History
                
                 |
                  Source
                 | Raw
                 |Copy content
                 |Copy permalink

        marcink
    
starting celery branch

              r467
            
      # List of modules to import when celery starts.

      import sys

      import os

        marcink
    
Removed config names from whoosh and celery,...

              r483
            
      import ConfigParser

        marcink
    
fixed up celeryconfig, to get results database from config files

              r484
            
      root = os.getcwd()

        marcink
    
Removed config names from whoosh and celery,...

              r483
            
        marcink
    
refactoring for new vcs implementation...

              r512
            
      PYLONS_CONFIG_NAME = 'production.ini'

        marcink
    
Removed config names from whoosh and celery,...

              r483
            
        marcink
    
fixed up celeryconfig, to get results database from config files

              r484
            
      sys.path.append(root)

        marcink
    
Removed config names from whoosh and celery,...

              r483
            
      config = ConfigParser.ConfigParser({'here':root})

      config.read('%s/%s' % (root, PYLONS_CONFIG_NAME))

      PYLONS_CONFIG = config

      CELERY_IMPORTS = ("pylons_app.lib.celerylib.tasks",)

        marcink
    
starting celery branch

              r467
            
      ## Result store settings.

      CELERY_RESULT_BACKEND = "database"

        marcink
    
fixed up celeryconfig, to get results database from config files

              r484
            
      CELERY_RESULT_DBURI = dict(config.items('app:main'))['sqlalchemy.db1.url']

        marcink
    
implemented basic autoupdating statistics fetched from database

              r493
            
      CELERY_RESULT_SERIALIZER = 'json'

        marcink
    
starting celery branch

              r467
            
        marcink
    
Implemented password reset(forms/models/ tasks) and mailing tasks....

              r474
            
      BROKER_CONNECTION_MAX_RETRIES = 30

        marcink
    
starting celery branch

              r467
            
      ## 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"

        marcink
    
fixed lock decorator bug which didn't release the lock after func execution and rewrote the pidlock a little with Ask Solem suggestions!...

              r506
            
      CELERYD_MAX_TASKS_PER_CHILD = 3

        marcink
    
starting celery branch

              r467
            
        marcink
    
implemented basic autoupdating statistics fetched from database

              r493
            
      #Tasks will never be sent to the queue, but executed locally instead.

      CELERY_ALWAYS_EAGER = False

      #===============================================================================

      # 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 ".*" ".*" ".*"

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages

marcink starting celery branch	r467	# List of modules to import when celery starts.
		import sys
		import os
marcink Removed config names from whoosh and celery,...	r483	import ConfigParser
marcink fixed up celeryconfig, to get results database from config files	r484	root = os.getcwd()
marcink Removed config names from whoosh and celery,...	r483
marcink refactoring for new vcs implementation...	r512	PYLONS_CONFIG_NAME = 'production.ini'
marcink Removed config names from whoosh and celery,...	r483
marcink fixed up celeryconfig, to get results database from config files	r484	sys.path.append(root)
marcink Removed config names from whoosh and celery,...	r483	config = ConfigParser.ConfigParser({'here':root})
		config.read('%s/%s' % (root, PYLONS_CONFIG_NAME))
		PYLONS_CONFIG = config

		CELERY_IMPORTS = ("pylons_app.lib.celerylib.tasks",)
marcink starting celery branch	r467
		## Result store settings.
		CELERY_RESULT_BACKEND = "database"
marcink fixed up celeryconfig, to get results database from config files	r484	CELERY_RESULT_DBURI = dict(config.items('app:main'))['sqlalchemy.db1.url']
marcink implemented basic autoupdating statistics fetched from database	r493	CELERY_RESULT_SERIALIZER = 'json'

marcink starting celery branch	r467
marcink Implemented password reset(forms/models/ tasks) and mailing tasks....	r474	BROKER_CONNECTION_MAX_RETRIES = 30
marcink starting celery branch	r467
		## 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"
marcink fixed lock decorator bug which didn't release the lock after func execution and rewrote the pidlock a little with Ask Solem suggestions!...	r506	CELERYD_MAX_TASKS_PER_CHILD = 3
marcink starting celery branch	r467
marcink implemented basic autoupdating statistics fetched from database	r493	#Tasks will never be sent to the queue, but executed locally instead.
		CELERY_ALWAYS_EAGER = False

		#===============================================================================
		# 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 "." "." ".*"