This document describes the current stable version of Celery (4.2). For development docs, go here.
Source code for celery.worker.consumer.agent
"""Celery + :pypi:`cell` integration."""
from __future__ import absolute_import, unicode_literals
from celery import bootsteps
from .connection import Connection
__all__ = ('Agent',)
[docs]class Agent(bootsteps.StartStopStep):
"""Agent starts :pypi:`cell` actors."""
conditional = True
requires = (Connection,)
def __init__(self, c, **kwargs):
self.agent_cls = self.enabled = c.app.conf.worker_agent
super(Agent, self).__init__(c, **kwargs)
return agent