Yohohohohohooho | Sanrei Aya
Sanrei Aya


Server : LiteSpeed
System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64
User : elvh3918 ( 1528)
PHP Version : 8.2.31
Disable Function : mail
Directory :  /usr/local/lib/python3.9/site-packages/celery/worker/consumer/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Current File : //usr/local/lib/python3.9/site-packages/celery/worker/consumer/__pycache__/control.cpython-39.pyc
a

��Sh��@sVdZddlmZddlmZddlmZddlmZdZ	ee
�ZGdd	�d	ej�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)�Controlcs.eZdZdZefZ�fdd�Zdd�Z�ZS)rzRemote control command service.csb|jduo|jj|_|jr tjntj|�|_|jj|_|jj|_|jj|_t	�j
|fi|��dS)N)�poolZis_greenrZgPidboxZPidboxZbox�start�stop�shutdown�super�__init__)�self�c�kwargs��	__class__��H/usr/local/lib/python3.9/site-packages/celery/worker/consumer/control.pyr
s


zControl.__init__cCs|jjjo|j�d�S)NZfanout)Zapp�confZworker_enable_remote_controlZconninfoZsupports_exchange_type)rrrrr�
include_ifs

�zControl.include_if)	�__name__�
__module__�__qualname__�__doc__r�requiresr
r�
__classcell__rrrrrsrN)rZceleryrZcelery.utils.logrZ
celery.workerr�tasksr�__all__r�loggerZ
StartStopSteprrrrr�<module>s

Yohohohohohooho | Sanrei Aya