U Z¨+d ã@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|f|ŽdS©N)ZappÚconfZ worker_agentÚ agent_clsZenabledÚsuperÚ__init__)ÚselfÚcÚkwargs©Ú __class__©ú@/tmp/pip-unpacked-wheel-ucduq0nd/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