Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(6)  |  Call(6)  |  Derive(0)  |  Import(0)

src/a/n/antisocial-HEAD/ve/lib/python2.7/site-packages/celery/worker/__init__.py   antisocial(Download)
 
        self._shutdown_complete = Event()
        self.setup_defaults(kwargs, namespace='celeryd')
        self.app.select_queues(queues)  # select queues subset.
 

src/f/i/firefox-flicks-HEAD/vendor-local/lib/python/celery/worker/__init__.py   firefox-flicks(Download)
 
        self._shutdown_complete = Event()
        self.setup_defaults(kwargs, namespace='celeryd')
        self.app.select_queues(queues)  # select queues subset.
 

src/a/n/antisocial-HEAD/ve/lib/python2.7/site-packages/celery/apps/worker.py   antisocial(Download)
                                  conf=self.app.conf)
 
        self.setup_defaults(kwargs, namespace='celeryd')
        if not self.concurrency:
            try:

src/a/n/antisocial-HEAD/ve/lib/python2.7/site-packages/celery/apps/beat.py   antisocial(Download)
    def __init__(self, max_interval=None, app=None,
                 socket_timeout=30, pidfile=None, no_color=None, **kwargs):
        """Starts the celerybeat task scheduler."""
        self.app = app = app_or_default(app or self.app)
        self.setup_defaults(kwargs, namespace='celerybeat')

src/f/i/firefox-flicks-HEAD/vendor-local/lib/python/celery/apps/worker.py   firefox-flicks(Download)
                                  conf=self.app.conf)
 
        self.setup_defaults(kwargs, namespace='celeryd')
        if not self.concurrency:
            try:

src/f/i/firefox-flicks-HEAD/vendor-local/lib/python/celery/apps/beat.py   firefox-flicks(Download)
    def __init__(self, max_interval=None, app=None,
                 socket_timeout=30, pidfile=None, no_color=None, **kwargs):
        """Starts the celerybeat task scheduler."""
        self.app = app = app_or_default(app or self.app)
        self.setup_defaults(kwargs, namespace='celerybeat')