Name	Size	Mode	Actions
__pycache__/	-	0755	rm
agent.py	525	0644	editdlrm
connection.py	1026	0644	editdlrm
consumer.py	29091	0644	editdlrm
control.py	946	0644	editdlrm
events.py	2054	0644	editdlrm
gossip.py	6863	0644	editdlrm
heart.py	930	0644	editdlrm
mingle.py	2519	0644	editdlrm
tasks.py	1960	0644	editdlrm
__init__.py	391	0644	editdlrm

"""Celery + :pypi:`cell` integration.""" from celery import bootsteps from .connection import Connection __all__ = ('Agent',) 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().__init__(c, **kwargs) def create(self, c): agent = c.agent = self.instantiate(self.agent_cls, c.connection) return agent