o
    h                     @   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 )zWorker 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__ `/var/www/html/optinet_system/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    