
    `f                     L    d Z ddlmZ ddlmZ dZ G d dej                  ZdS )	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                 v    |j         j        j        x| _        | _         t                      j        |fi | d S N)appconfworker_agent	agent_clsenabledsuper__init__)selfckwargs	__class__s      N/var/www/html/env/lib/python3.11/site-packages/celery/worker/consumer/agent.pyr   zAgent.__init__   s=    ()
(??%%f%%%%%    c                 T    |                      | j        |j                  x}|_        |S r	   )instantiater   
connectionagent)r   r   r   s      r   createzAgent.create   s'    **4>1<HHHr   )
__name__
__module____qualname____doc__conditionalr   requiresr   r   __classcell__)r   s   @r   r   r   	   sY        ++K}H& & & & &      r   r   N)r   celeryr   r   r   __all__StartStopStepr    r   r   <module>r'      sk    ( (       " " " " " "
    I#     r   