o
    ©D®f²  ã                   @   sV   d Z ddlmZ ddlmZ ddlmZ ddlmZ dZ	ee
ƒZG dd	„ d	ejƒZd
S )zªWorker Remote Control Bootstep.

``Control`` -> :mod:`celery.worker.pidbox` -> :mod:`kombu.pidbox`.

The actual commands are implemented in :mod:`celery.worker.control`.
é    )Ú	bootsteps)Ú
get_logger)Úpidboxé   )ÚTasks)ÚControlc                       s.   e Zd ZdZefZ‡ fdd„Zdd„ Z‡  ZS )r   zRemote control command service.c                    sb   |j d uo|j j| _| jrtjntj|ƒ| _| jj| _| jj| _| jj| _t	ƒ j
|fi |¤Ž d S )N)ÚpoolÚis_greenr   ÚgPidboxÚPidboxÚboxÚstartÚstopÚshutdownÚsuperÚ__init__)ÚselfÚcÚkwargs©Ú	__class__© úW/home/ubuntu/webapp/venv/lib/python3.10/site-packages/celery/worker/consumer/control.pyr      s   


zControl.__init__c                 C   s   |j jjo
|j d¡S )NÚfanout)ÚappÚconfÚworker_enable_remote_controlÚconninfoÚsupports_exchange_type)r   r   r   r   r   Ú
include_if   s   

ÿzControl.include_if)	Ú__name__Ú
__module__Ú__qualname__Ú__doc__r   Úrequiresr   r   Ú__classcell__r   r   r   r   r      s
    r   N)r#   Úceleryr   Úcelery.utils.logr   Úcelery.workerr   Útasksr   Ú__all__r    ÚloggerÚStartStopStepr   r   r   r   r   Ú<module>   s    