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

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

src/o/h/oh-mainline-HEAD/vendor/packages/django-celery/examples/clickcounter/clickmuncher/actors.py   oh-mainline(Download)
    def __init__(self, connection=None, *args, **kwargs):
        if not connection:
            connection = celery.broker_connection()
        super(Clicks, self).__init__(connection, *args, **kwargs)
 
    def __init__(self, connection=None, *args, **kwargs):
        if not connection:
            connection = celery.broker_connection()
        self.clicks = Clicks()
        self.actors = [self.clicks]

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/e/cell-0.0.3/examples/clex.py   cell(Download)
        # - to the celery config.
        super(BlenderActor, self).__init__(
            connection or celery.broker_connection(), *args, **kwargs)
 
    class state:
    def __init__(self, connection=None, *args, **kwargs):
        # - use celery's connection by default
        super(Agent, self).__init__(
            connection or celery.broker_connection(), *args, **kwargs)
 

src/c/e/cell-HEAD/examples/clex.py   cell(Download)
        # - to the celery config.
        super(BlenderActor, self).__init__(
            connection or celery.broker_connection(), *args, **kwargs)
 
    class state:
    def __init__(self, connection=None, *args, **kwargs):
        # - use celery's connection by default
        super(Agent, self).__init__(
            connection or celery.broker_connection(), *args, **kwargs)
 

src/c/y/cyme-0.0.5/cyme/models/__init__.py   cyme(Download)
    def connection(self):
        return celery.broker_connection(self.url)
 
 
class App(models.Model):

src/c/y/cyme-HEAD/cyme/models/__init__.py   cyme(Download)
    def connection(self):
        return celery.broker_connection(self.url)
 
 
class App(models.Model):

src/c/y/cyme-0.0.5/cyme/management/commands/cyme.py   cyme(Download)
    def all_branches(self):
        from cyme.branch.controller import Branch
        args = [self.broker] if self.broker else []
        conn = celery.broker_connection(*args)
        return Branch(connection=conn).all(limit=self.limit)

src/c/y/cyme-HEAD/cyme/management/commands/cyme.py   cyme(Download)
    def all_branches(self):
        from cyme.branch.controller import Branch
        args = [self.broker] if self.broker else []
        conn = celery.broker_connection(*args)
        return Branch(connection=conn).all(limit=self.limit)

  1 | 2 | 3  Next