upstream/kallithea Files · celeryconfig.py

fixes few bugs...

fixes few bugs - fixed python2.5 incompatible enumerate calls - fixed disable mercurial extension for web - fixed deleting repositories don't delete it's dependent objects - small css updated

marcink - - Load All Authors

File last commit:

r547:1e757ac9 default


                r671:bee56f20

rhodecode-0.0.1.0.1 default

Download file

             celeryconfig.py
        
                    77 lines
            
             | 2.5 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
    
some fixups in cache, added fallback and cache invalidation when key not found in cached repos list,...

              r535
            
      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

        marcink
    
renamed project to rhodecode

              r547
            
      CELERY_IMPORTS = ("rhodecode.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

        marcink
    
updated tests for new version 6char password etc...

              r533
            
      if PYLONS_CONFIG_NAME == 'test.ini':

          #auto eager for tests

          CELERY_ALWAYS_EAGER = True

        marcink
    
implemented basic autoupdating statistics fetched from database

              r493
            
      #===============================================================================

      # 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 some fixups in cache, added fallback and cache invalidation when key not found in cached repos list,...	r535	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

marcink renamed project to rhodecode	r547	CELERY_IMPORTS = ("rhodecode.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
marcink updated tests for new version 6char password etc...	r533	if PYLONS_CONFIG_NAME == 'test.ini':
		#auto eager for tests
		CELERY_ALWAYS_EAGER = True
marcink implemented basic autoupdating statistics fetched from database	r493
		#===============================================================================
		# 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 "." "." ".*"