o
    h                     @   s6   d Z ddlmZ ddlmZ dZG dd dejZdS )	z"Celery + :pypi:`cell` integration.    )	bootsteps   )
Connection)Agentc                       s2   e Zd ZdZdZefZ fddZdd Z  Z	S )r   z!Agent starts :pypi:`cell` actors.Tc                    s*   |j jj | _| _t j|fi | d S N)appconfworker_agent	agent_clsenabledsuper__init__)selfckwargs	__class__ ^/var/www/html/optinet_system/venv/lib/python3.10/site-packages/celery/worker/consumer/agent.pyr      s   zAgent.__init__c                 C   s   |  | j|j }|_|S r   )instantiater
   
connectionagent)r   r   r   r   r   r   create   s   zAgent.create)
__name__
__module____qualname____doc__conditionalr   requiresr   r   __classcell__r   r   r   r   r   	   s    r   N)r   celeryr   r   r   __all__StartStopStepr   r   r   r   r   <module>   s
    