o ©D®f¢ã@sBdZddlmZddlmZddlmZdZGdd„dejƒZ d S) z Worker Event Heartbeat Bootstep.é)Ú bootsteps)Ú heartbeaté)ÚEvents)ÚHeartcs>eZdZdZefZ d ‡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|fi|¤ŽdS©N)ÚenabledÚheartbeat_intervalÚheartÚsuperÚ__init__)ÚselfÚcÚwithout_heartbeatr Úkwargs©Ú __class__©úU/home/ubuntu/webapp/venv/lib/python3.10/site-packages/celery/worker/consumer/heart.pyr szHeart.__init__cCs$t |j|j|j¡|_|j ¡dSr)rrÚtimerÚevent_dispatcherr r Ústart©r rrrrrs ÿz Heart.startcCs|jo|j ¡|_dSr)r Ústoprrrrr"sz Heart.stop)FN) Ú__name__Ú __module__Ú __qualname__Ú__doc__rÚrequiresr rrÚshutdownÚ __classcell__rrrrr sÿ rN) rÚceleryrÚ celery.workerrÚeventsrÚ__all__Ú StartStopSteprrrrrÚs