o
    ©D®f  ã                   @   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__© úU/home/ubuntu/webapp/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
    