This document describes the current stable version of Celery (4.0). 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 = super(Agent, self).__init__(c, **kwargs)
[docs] def create(self, c): agent = c.agent = self.instantiate(self.agent_cls, c.connection) return agent