o wvXj9 @s|dZddlmZmZddlmZddlmZddlm Z ddl m Z dZ e e ZejejejZZZGd d d ejZd S) z-Worker <-> Worker Sync at startup (Bootstep).)absolute_importunicode_literals) bootsteps)items) get_logger)Events)MinglecsveZdZdZdZefZddhZdfdd ZddZ d d Z d d Z d dZ ddZ dddZddZddZZS)r zBootstep syncing state with neighbor workers. At startup, or upon consumer restart, this will: - Sync logical clocks. - Sync revoked tasks. amqpredisFc s4| o||j|_tt|j|fd|i|dS)Nwithout_mingle)compatible_transportappenabledsuperr __init__)selfcr kwargs __class__Z/var/www/html/myproject/venv/lib/python3.10/site-packages/celery/worker/consumer/mingle.pyrs  zMingle.__init__cCs:|}|jj|jvWdS1swYdSN)connection_for_read transport driver_typecompatible_transports)rrconnrrrr #s  $zMingle.compatible_transportcCs||dSr)sync)rrrrrstart'sz Mingle.startcsbtd}|r+tdtddt|Dfddt|DtddStddS)Nzmingle: searching for neighborszmingle: sync with %s nodescSsg|]\}}|r|qSrr).0replyvaluerrr /szMingle.sync..cs"g|] \}}|r||qSr) on_node_reply)r!nodenamer"rrrrr$0szmingle: sync completezmingle: all alone)info send_hellolenr)rrrepliesrr'rr*s    z Mingle.synccCsD|jjjd|jd}|jjj}||j|j pi}| |jd|S)Ng?)timeout connection) rcontrolinspectr- controllerstaterevokedhellohostname_datapop)rrr/ our_revokedr+rrrr)6s  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&r"excrrrr%=s  zMingle.on_node_replyNcKs||||||dSr)on_clock_eventon_revoked_received)rrclockr2rrrrr9Fs zMingle.sync_with_nodecCs&|r |jj|dS|jjdSr)rr@adjustforward)rrr@rrrr>Js&zMingle.on_clock_eventcCs|r |jjj|dSdSr)r0r1r2update)rrr2rrrr?MszMingle.on_revoked_received)F)NN)__name__ __module__ __qualname____doc__labelrrequiresrrr r rr)r%r9r>r? __classcell__rrrrr s   r N)rG __future__rrceleryr celery.fivercelery.utils.logreventsr__all__rDloggerr8r(r< StartStopStepr rrrrs