iZdZddlmZddlmZddlmZdZGddejZ y ) z Worker Event Heartbeat Bootstep.) bootsteps) heartbeat)Events)Heartc<eZdZdZefZ dfd ZdZdZeZ xZ S)rzBootstep sending event heartbeats. This service sends a ``worker-heartbeat`` message every n seconds. Note: Not to be confused with AMQP protocol level heartbeats. c R| |_||_d|_t||fi|yN)enabledheartbeat_intervalheartsuper__init__)selfcwithout_heartbeatr kwargs __class__s Z/var/www/html/eduruby.in/venv/lib/python3.12/site-packages/celery/worker/consumer/heart.pyrzHeart.__init__s.,, "4 %f%ctj|j|j|j|_|j j yr )rrtimerevent_dispatcherr r startrrs rrz Heart.starts8// GGQ'')@)@   rc^|jxr|jj|_yr )r stoprs rrz Heart.stop"s'',aggllnr)FN) __name__ __module__ __qualname____doc__rrequiresrrrshutdown __classcell__)rs@rrr s+yH>B& -HrrN) r!celeryr celery.workerreventsr__all__ StartStopSteprrrr+s(&# I # #r