/usr/lib/python2.7/dist-packages/celery/worker/consumer/agent.py is in python-celery 4.1.0-2ubuntu1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 | """Celery + :pypi:`cell` integration."""
from __future__ import absolute_import, unicode_literals
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(Agent, self).__init__(c, **kwargs)
def create(self, c):
agent = c.agent = self.instantiate(self.agent_cls, c.connection)
return agent
|