(ph8SSKrSSKrSSKrSSKrSSKJrJrJrJr SSK J r SSK J r J r SSKJr \R "5 SSKJr SSKJr SSKJrJr SS KJrJrJrJ r J!r!J"r" SS K#J$r$ SS K%J&r& SS K'J(r( SS K)J*r* SSK+J,r, SSK-J.r.J/r/ SSK0J1r1 "SS5r2"SS5r3\Rh(+4S\5S\6S\74Sjjr8g!\ R"R$a SSK r \ R&"5 Nf=f)N)EventProcessValuecurrent_process)sleep)coredb)apps)timezone) gettext_lazy)Broker get_broker)Confget_ppidloggerprometheus_multiprocesspsutil setproctitle)humanize)monitor)pusher)Queue) scheduler)StatStatus)workerc\rSrSrSS\4SjjrS\4SjrS\4Sjr Sr \ S\ 4S j5r \ S\4S j5r\ S\4S j5r\ S\4S j5r\ S\4S j5r\ S\4Sj5rSrg)Cluster*NbrokercXlSUlSUlSUl[ 5R Ul[ R"5Ul[R"5Ul SUl [R"[RUR5 [R"[R UR5 gN)r sentinel stop_event start_eventrpiduuiduuid4 cluster_idsocket gethostnamehosttimeoutsignalSIGTERM sig_handlerSIGINT)selfr s C/var/www/html/venv/lib/python3.13/site-packages/django_q/cluster.py__init__Cluster.__init__+s  "$((**,&&(   fnnd&6&67 fmmT%5%56returnc [(a8[R"S[5RSUR35 [5Ul[5Ul[ [S[R"5R3URUR URURUR4S9UlURR5 [ R""[%S5SUR0-5 UR R'5(d,[)S5 UR R'5(dM,UR*$)Nz qcluster  Process-)targetnameargszQ Cluster %(name)s starting.r<皙?)rrr<rr$r%rSentinelr'r(hexr)r r-r#startrinfo_is_setrr&r2s r3rA Cluster.start9s <  % % /2C2H2H1I499+&V W' 7DJJL,,-.         A458KKL""))++ #J""))++xxr6cURR5(dg[R"[ S5SUR 0-5 UR R5 URR5 [R"[ S5SUR 0-5 SUl SUlg)NFzQ Cluster %(name)s stopping.r<zQ Cluster %(name)s has stopped.T) r#is_aliverrBrCr<r$setjoinr%rEs r3stop Cluster.stopPs}}%%'' A458KKL   A78FDII;NNOr6c[R"[S5[5R[ R RUS5S.-5 UR5 g)Nz%(name)s got signal %(signal)sUNKNOWN)r<r.) rdebugrCrr<r SIGNAL_NAMESgetrK)r2signumframes r3r0Cluster.sig_handler[sN . /')..++// B   r6cUR(a)[R"URURS9$[ URURS9$)N)r&r))r#rrQr&r)rrEs r3stat Cluster.states7 ==88T__E E$((t??r6c@[URR5$r")rr)r@rEs r3r< Cluster.nameks++,,r6cUR=(a2 UR=(a URR5(+$r"r$r%rDrEs r3 is_startingCluster.is_startingos.U4#3#3UD$& .$,, /3/?/?E$** +UW "G   JJL r6cTUR(aURR$S$)Nz--)r list_keyrEs r3 queue_nameSentinel.queue_names'+{{t{{##<*>*@*@C NUVDV}}$<< +D %r6c[XS[R"5R3S9nSUlU[ :Xa:[ RUlUSUlURRU5 UR5 U$)z! :type target: function or class r:)r;r=r<T) rr'r(r@daemonrrDAEMONIZE_WORKERStimerr}appendrA)r2r;r=ps r3 spawn_processSentinel.spawn_processsk 6Xdjjl>N>N=O3P Q V --AH1gAG II  Q   r6cnUR[URURUR5$r")rrrrr rEs r3 spawn_pusherSentinel.spawn_pushers%!!&$//4>>4;;WWr6c UR[URUR[ SS5UR 5 g)Nf)rrrrrr-rEs r3 spawn_workerSentinel.spawn_workers/  DOOT%6%6c2  r6cXUR[URUR5$r")rrrr rEs r3 spawn_monitorSentinel.spawn_monitors!!!'4+<+S- slg![.R6a GNf=f)zK :param process: the process to reincarnate :type process: Process or None z0reincarnated monitor %(name)s after sudden deathr<z/reincarnated pusher %(name)s after sudden deathPROMETHEUS_MULTIPROC_DIRprometheus_multiproc_dirrr9r processingzNreincarnated worker %(name)s after timeout while processing task %(task_name)s)r< task_namez*reincarnated worker %(name)s after timeoutzrecycled worker %(name)sz(reincarnated worker %(name)s after deathN) rSYNCr connections close_allrrrcriticalrCr<rrosgetenvrmark_process_deadr&r}removerrvaluerrsplitr NoSuchProcess terminaterkrBrx)r2processprometheus_pathr process_name name_splitsmsgs r3 reincarnateSentinel.reincarnatesX yy NN $ $ & ll "--/DL OODE7<<()  #++-DK OOCD7<<()  !ii*BII6P,QO'&?'99'++F II  W %    }}""a' 6 '-~~gkk'B'G'G'I &2&8&8&=  #;/14Q<9W(N!#"!!#h!(IFGCHI MC$W]](()R/ A89VW\\STOPz!%(name)s waiting for the monitor.rr r)rrrr<rrBrCrrIrrHrrrr}rputclose join_threadrrr-rrr)r2r<rrcounts r3rK Sentinel.stopWs T  %% A;<~MN kk""$$ #J JOO kk""$$DII'B OO   '(  ##%$))nnYYzz||II$$Q' #J JOO  $))nn f% ! %%' A9:fd^KL||DLkkmt}},9J1J #J JOO  QJEkkmt}},9J1J T r6)r r)rrr<rwr&r}r|rrxrr%r$rr-rz)NNT)rgrhrirjr4rrArnrrrrrrrrrrKrorpr6r3r?r?sn  D=     g XgX KwK@!DL .`&r6r?n process_idsactualc[(d [R"[S55 gU(aI[ [R "US5S5(d![R"[S55 Sn[ [[R"555nU(aU[U5:agSnUHn/n[U5H,nU[U5:XaSnURX45 US- nM. [R"U5(dM][R "U5nU(aURU5 [R"[S5XVS .-5 M g) z Sets the cpu affinity for the supplied processes. Requires the optional psutil module. :param int n: affinity :param list process_ids: a list of pids :param bool actual: Test workaround for Travis not supporting cpu affinity z3Skipping cpu affinity because psutil was not found.Nr cpu_affinityz@Faking cpu affinity because it is not supported on this platformFrz!%(pid)s will use cpu %(affinity)s)r&affinity)rrwarningrChasattrrlistr cpu_countrr pid_existsrrB) rrrcpu_listindexr&rkrs r3rrs 6qNOP gfnn[^rs BB% "60($"!(("XVXVvxxvDH<