File: //usr/local/lib/python3.9/site-packages/celery/worker/consumer/__pycache__/agent.cpython-39.pyc
a
X>h
� @ s6 d Z ddlmZ ddlmZ dZG dd� dej�ZdS ) z"Celery + :pypi:`cell` integration.� )� bootsteps� )�
Connection)�Agentc s2 e Zd ZdZdZefZ� fdd�Zdd� Z� Z S )r z!Agent starts :pypi:`cell` actors.Tc s* |j jj | _| _t� j|fi |�� d S �N)Zapp�confZ worker_agent� agent_cls�enabled�super�__init__)�self�c�kwargs�� __class__� �F/usr/local/lib/python3.9/site-packages/celery/worker/consumer/agent.pyr s zAgent.__init__c C s | � | j|j� }|_|S r )Z instantiater �
connection�agent)r r
r r r r �create s z Agent.create)
�__name__�
__module__� __qualname__�__doc__Z conditionalr �requiresr r �
__classcell__r r r r r s
r N)r Zceleryr r r �__all__Z
StartStopStepr r r r r �<module> s