
    h                     N    d Z ddlmZ ddlmZ dZ G d dej                        Zy)	z"Celery + :pypi:`cell` integration.    )	bootsteps   )
Connection)Agentc                   2     e Zd ZdZdZefZ fdZd Z xZ	S )r   z!Agent starts :pypi:`cell` actors.Tc                 ~    |j                   j                  j                  x| _        | _        t        |   |fi | y N)appconfworker_agent	agent_clsenabledsuper__init__)selfckwargs	__class__s      X/var/www/Befach/backend/env/lib/python3.12/site-packages/celery/worker/consumer/agent.pyr   zAgent.__init__   s1    ()

(?(??%f%    c                 `    | j                  | j                  |j                        x}|_        |S r	   )instantiater   
connectionagent)r   r   r   s      r   createzAgent.create   s(    **4>>1<<HHr   )
__name__
__module____qualname____doc__conditionalr   requiresr   r   __classcell__)r   s   @r   r   r   	   s    +K}H&r   r   N)r   celeryr   r   r   __all__StartStopStepr    r   r   <module>r'      s%    (  "
I## r   