o Df @s`dZddlmZddlmZddlmZdZeeZ e j e j e j Z Z Z Gdddej Zd S) z-Worker <-> Worker Sync at startup (Bootstep).) bootsteps) get_logger)Events)MinglecsveZdZdZdZefZddhZdfdd ZddZ d d Z d d Z d dZ ddZ dddZddZddZZS)rzBootstep syncing state with neighbor workers. At startup, or upon consumer restart, this will: - Sync logical clocks. - Sync revoked tasks. amqpredisFc s0| o||j|_tj|fd|i|dS)Nwithout_mingle)compatible_transportappenabledsuper__init__)selfcr kwargs __class__V/home/ubuntu/webapp/venv/lib/python3.10/site-packages/celery/worker/consumer/mingle.pyrs zMingle.__init__cCs:|}|jj|jvWdS1swYdSN)connection_for_read transport driver_typecompatible_transports)rr connrrrr s  $zMingle.compatible_transportcCs||dSr)sync)rrrrrstart$sz Mingle.startcsbtd}|r+tdtdd|Dfdd|DtddStddS)Nzmingle: searching for neighborszmingle: sync with %s nodescSsg|]\}}|r|qSrr).0replyvaluerrr ,szMingle.sync..cs"g|] \}}|r||qSr) on_node_reply)rnodenamerrrrrr!-szmingle: sync completezmingle: all alone)info send_hellolenitems)rrrepliesrr$rr's    z Mingle.synccCsD|jjjd|jd}|jjj}||j|j pi}| |jd|S)Ng?)timeout connection) r controlinspectr+ controllerstaterevokedhellohostname_datapop)rrr- our_revokedr)rrrr&3s  zMingle.send_helloc Csdtd|z |j|fi|WdStyty1}z td||WYd}~dSd}~ww)Nz mingle: processing reply from %szmingle: sync with %s failed: %r)debugsync_with_node MemoryError Exception exception)rrr#rexcrrrr":s  zMingle.on_node_replyNcKs||||||dSr)on_clock_eventon_revoked_received)rrclockr0rrrrr7Cs zMingle.sync_with_nodecCs&|r |jj|dS|jjdSr)r r>adjustforward)rrr>rrrr<Gs&zMingle.on_clock_eventcCs|r |jjj|dSdSr)r.r/r0update)rrr0rrrr=JszMingle.on_revoked_received)F)NN)__name__ __module__ __qualname____doc__labelrrequiresrrr rrr&r"r7r<r= __classcell__rrrrr s   rN)rEceleryrcelery.utils.logreventsr__all__rBloggerr6r%r: StartStopSteprrrrrs