This document describes the current stable version of Celery (4.0). For development docs, go here.

celery.worker.consumer.agent

Celery + cell integration.

class celery.worker.consumer.agent.Agent(c, **kwargs)[source]

Agent starts cell actors.

conditional = True
create(c)[source]
name = u'celery.worker.consumer.agent.Agent'
requires = (step:celery.worker.consumer.connection.Connection{()},)