a Šxd ã@s6dZddlmZddlmZdZGdd„dejƒZdS) z"Celery + :pypi:`cell` integration.é)Ú bootstepsé)Ú Connection)ÚAgentcs2eZdZdZdZefZ‡fdd„Zdd„Z‡Z S)rz!Agent starts :pypi:`cell` actors.Tc s*|jjj|_|_tƒj|fi|¤ŽdS©N)ZappÚconfZ worker_agentÚ agent_clsZenabledÚsuperÚ__init__)ÚselfÚcÚkwargs©Ú __class__©úT/var/www/html/Ranjet/env/lib/python3.9/site-packages/celery/worker/consumer/agent.pyr szAgent.__init__cCs| |j|j¡}|_|Sr)Z instantiaterÚ connectionÚagent)r r rrrrÚcreatesz Agent.create) Ú__name__Ú __module__Ú __qualname__Ú__doc__Z conditionalrÚrequiresr rÚ __classcell__rrrrr s  rN)rZceleryrrrÚ__all__Z StartStopSteprrrrrÚs