o h@sBdZddlmZddlmZddlmZdZGdddejZ d S) z Worker Event Heartbeat Bootstep.) bootsteps) heartbeat)Events)Heartcs>eZdZdZefZ d fdd ZddZdd ZeZ Z 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. FNc s,| |_||_d|_tj|fi|dSN)enabledheartbeat_intervalheartsuper__init__)selfcwithout_heartbeatr kwargs __class__^/var/www/html/optinet_system/venv/lib/python3.10/site-packages/celery/worker/consumer/heart.pyr szHeart.__init__cCs$t|j|j|j|_|jdSr)rrtimerevent_dispatcherr r startr rrrrrs z Heart.startcCs|jo|j|_dSr)r stoprrrrr"sz Heart.stop)FN) __name__ __module__ __qualname____doc__rrequiresr rrshutdown __classcell__rrrrr s rN) rceleryr celery.workerreventsr__all__ StartStopSteprrrrrs