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

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

src/o/h/oh-mainline-HEAD/vendor/packages/celery/examples/eventlet/bulk_task_producer.py   oh-mainline(Download)
    def _producer(self):
        connection = current_app.broker_connection()
        publisher = current_app.amqp.TaskPublisher(connection)
        inqueue = self.inqueue
 

src/k/u/kuma-lib-HEAD/packages/celery/examples/eventlet/bulk_task_producer.py   kuma-lib(Download)
    def _producer(self):
        connection = current_app.broker_connection()
        publisher = current_app.amqp.TaskPublisher(connection)
        inqueue = self.inqueue
 

src/o/p/openquake-packages-HEAD/celery/examples/eventlet/bulk_task_producer.py   openquake-packages(Download)
    def _producer(self):
        connection = current_app.broker_connection()
        publisher = current_app.amqp.TaskPublisher(connection)
        inqueue = self.inqueue
 

src/c/y/cyme-0.0.5/cyme/api/views.py   cyme(Download)
        with broker.producers.acquire(block=True) as producer:
            publisher = celery.amqp.TaskPublisher(
                            connection=producer.connection,
                            channel=producer.channel)
            result = webhook.apply_async((url, method, params, data),

src/c/y/cyme-HEAD/cyme/api/views.py   cyme(Download)
        with broker.producers.acquire(block=True) as producer:
            publisher = celery.amqp.TaskPublisher(
                            connection=producer.connection,
                            channel=producer.channel)
            result = webhook.apply_async((url, method, params, data),