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

"""Worker Remote Control Bootstep. ``Control`` -> :mod:`celery.worker.pidbox` -> :mod:`kombu.pidbox`. The actual commands are implemented in :mod:`celery.worker.control`. """ from celery import bootsteps from celery.utils.log import get_logger from celery.worker import pidbox from .tasks import Tasks __all__ = ('Control',) logger = get_logger(__name__) class Control(bootsteps.StartStopStep): """Remote control command service.""" requires = (Tasks,) def __init__(self, c, **kwargs): self.is_green = c.pool is not None and c.pool.is_green self.box = (pidbox.gPidbox if self.is_green else pidbox.Pidbox)(c) self.start = self.box.start self.stop = self.box.stop self.shutdown = self.box.shutdown super().__init__(c, **kwargs) def include_if(self, c): return (c.app.conf.worker_enable_remote_control and c.conninfo.supports_exchange_type('fanout'))