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

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

src/c/e/celery-3.1.11/celery/worker/consumer.py   celery(Download)
class Connection(bootsteps.StartStopStep):
 
    def __init__(self, c, **kwargs):
        c.connection = None
 
class Events(bootsteps.StartStopStep):
    requires = (Connection, )
 
    def __init__(self, c, send_events=None, **kwargs):
        self.send_events = True
class Heart(bootsteps.StartStopStep):
    requires = (Events, )
 
    def __init__(self, c, without_heartbeat=False, heartbeat_interval=None,
                 **kwargs):
class Mingle(bootsteps.StartStopStep):
    label = 'Mingle'
    requires = (Events, )
    compatible_transports = set(['amqp', 'redis'])
 
class Tasks(bootsteps.StartStopStep):
    requires = (Mingle, )
 
    def __init__(self, c, **kwargs):
        c.task_consumer = c.qos = None

src/c/e/celery-HEAD/celery/worker/consumer.py   celery(Download)
class Connection(bootsteps.StartStopStep):
 
    def __init__(self, c, **kwargs):
        c.connection = None
 
class Events(bootsteps.StartStopStep):
    requires = (Connection, )
 
    def __init__(self, c, send_events=None, **kwargs):
        self.send_events = True
class Heart(bootsteps.StartStopStep):
    requires = (Events, )
 
    def __init__(self, c, without_heartbeat=False, heartbeat_interval=None,
                 **kwargs):
class Mingle(bootsteps.StartStopStep):
    label = 'Mingle'
    requires = (Events, )
    compatible_transports = {'amqp', 'redis'}
 
class Tasks(bootsteps.StartStopStep):
    requires = (Mingle, )
 
    def __init__(self, c, **kwargs):
        c.task_consumer = c.qos = None

src/c/e/celery-3.1.11/celery/worker/components.py   celery(Download)
class Hub(bootsteps.StartStopStep):
    requires = (Timer, )
 
    def __init__(self, w, **kwargs):
        w.hub = None
class Pool(bootsteps.StartStopStep):
    """Bootstep managing the worker pool.
 
    Describes how to initialize the worker pool, and starts and stops
    the pool during worker startup/shutdown.
class Beat(bootsteps.StartStopStep):
    """Step used to embed a beat process.
 
    This will only be enabled if the ``beat``
    argument is set.
class Consumer(bootsteps.StartStopStep):
    last = True
 
    def create(self, w):
        if w.max_concurrency:

src/c/e/celery-HEAD/celery/worker/components.py   celery(Download)
class Hub(bootsteps.StartStopStep):
    requires = (Timer, )
 
    def __init__(self, w, **kwargs):
        w.hub = None
class Pool(bootsteps.StartStopStep):
    """Bootstep managing the worker pool.
 
    Describes how to initialize the worker pool, and starts and stops
    the pool during worker startup/shutdown.
class Beat(bootsteps.StartStopStep):
    """Step used to embed a beat process.
 
    This will only be enabled if the ``beat``
    argument is set.
class Consumer(bootsteps.StartStopStep):
    last = True
 
    def create(self, w):
        if w.max_concurrency:

src/c/e/celery-3.1.11/celery/worker/autoscale.py   celery(Download)
class WorkerComponent(bootsteps.StartStopStep):
    label = 'Autoscaler'
    conditional = True
    requires = (Pool, )
 

src/c/e/celery-3.1.11/celery/worker/autoreload.py   celery(Download)
class WorkerComponent(bootsteps.StartStopStep):
    label = 'Autoreloader'
    conditional = True
    requires = (Pool, )
 

src/c/e/celery-HEAD/celery/worker/autoscale.py   celery(Download)
class WorkerComponent(bootsteps.StartStopStep):
    label = 'Autoscaler'
    conditional = True
    requires = (Pool, )
 

src/c/e/celery-HEAD/celery/worker/autoreload.py   celery(Download)
class WorkerComponent(bootsteps.StartStopStep):
    label = 'Autoreloader'
    conditional = True
    requires = (Pool, )
 

src/c/e/celery-HEAD/celery/tests/worker/test_bootsteps.py   celery(Download)
    class Def(bootsteps.StartStopStep):
        name = 'test_Step.Def'
 
    def setup(self):
        self.steps = []
    class Def(bootsteps.StartStopStep):
        name = 'test_StartStopStep.Def'
 
    def setup(self):
        self.steps = []

src/c/e/celery-3.1.11/celery/tests/worker/test_bootsteps.py   celery(Download)
    class Def(bootsteps.StartStopStep):
        name = 'test_Step.Def'
 
    def setup(self):
        self.steps = []
    class Def(bootsteps.StartStopStep):
        name = 'test_StartStopStep.Def'
 
    def setup(self):
        self.steps = []