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

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

src/c/e/celery-3.1.11/celery/worker/consumer.py   celery(Download)
class Gossip(bootsteps.ConsumerStep):
    label = 'Gossip'
    requires = (Mingle, )
    _cons_stamp_fields = itemgetter(
        'id', 'clock', 'hostname', 'pid', 'topic', 'action', 'cver',

src/c/e/celery-HEAD/celery/worker/consumer.py   celery(Download)
class Gossip(bootsteps.ConsumerStep):
    label = 'Gossip'
    requires = (Mingle, )
    _cons_stamp_fields = itemgetter(
        'id', 'clock', 'hostname', 'pid', 'topic', 'action', 'cver',

src/c/e/celery-3.1.11/celery/tests/worker/test_bootsteps.py   celery(Download)
    def test_interface(self):
        step = bootsteps.ConsumerStep(self)
        with self.assertRaises(NotImplementedError):
            step.get_consumers(self)
 
    def test_start_stop_shutdown(self):
        consumer = Mock()
        self.connection = Mock()
 
        class Step(bootsteps.ConsumerStep):
        class Step(bootsteps.ConsumerStep):
 
            def get_consumers(self, c):
                return ()
 

src/c/e/celery-HEAD/celery/tests/worker/test_bootsteps.py   celery(Download)
    def test_interface(self):
        step = bootsteps.ConsumerStep(self)
        with self.assertRaises(NotImplementedError):
            step.get_consumers(self)
 
    def test_start_stop_shutdown(self):
        consumer = Mock()
        self.connection = Mock()
 
        class Step(bootsteps.ConsumerStep):
        class Step(bootsteps.ConsumerStep):
 
            def get_consumers(self, c):
                return ()