U Z¨+d¢ã@sBdZddlmZddlmZddlmZdZGdd„dejƒZ d S) z Worker Event Heartbeat Bootstep.é)Ú bootsteps)Ú heartbeaté)ÚEvents)ÚHeartcs<eZdZdZefZd ‡fdd„ Zdd„Zdd „ZeZ ‡Z S) rzºBootstep sending event heartbeats. This service sends a ``worker-heartbeat`` message every n seconds. Note: Not to be confused with AMQP protocol level heartbeats. FNc s(| |_||_d|_tƒj|f|ŽdS©N)ZenabledÚheartbeat_intervalÚheartÚsuperÚ__init__)ÚselfÚcZwithout_heartbeatrÚkwargs©Ú __class__©ú@/tmp/pip-unpacked-wheel-ucduq0nd/celery/worker/consumer/heart.pyr szHeart.__init__cCs$t |j|j|j¡|_|j ¡dSr)rrZtimerZevent_dispatcherrr Ústart©r r rrrrs ÿz Heart.startcCs|jo|j ¡|_dSr)r Ústoprrrrr"sz Heart.stop)FN) Ú__name__Ú __module__Ú __qualname__Ú__doc__rÚrequiresr rrÚshutdownÚ __classcell__rrrrr sÿrN) rZceleryrZ celery.workerrÚeventsrÚ__all__Z StartStopSteprrrrrÚs