FgD}vSSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK J r SSK J r SSKJrJrJr SSKrSSKJrJrJr SSKJr SSKJr SS KJr SS KJr SS KJ r J!r!J"r"J#r#J$r$J%r%J&r&J'r'J(r( SS K)J*r*J+r+J,r,J-r-J.r. \(aSS K/J0r0J1r1 "SS5r2"SS5r3"SS5r4"SS5r g)) annotationsN) defaultdict)Queue) TYPE_CHECKINGLiteralcast) route_utilsroutes wasm_utils)PredictBodyInternal)Error)TrackedIterable) API_PREFIX) EstimationMessage EventMessage LogMessageProcessCompletedMessageProcessGeneratingMessageProcessStartsMessageProgressMessage ProgressUnit ServerMessage)LRUCache error_payloadrun_coro_in_background safe_get_lock set_task_name) BlockFunctionBlockscN\rSrSrSSjr\S5r\S5rSrg)Event.cN[R"5RUlU=(d URUlX lX0lX@lURUlSUl SUl SUl SUl SUl SUl[R "5Ulg)NFTr)uuiduuid4hex_id session_hashfnrequestusernameconcurrency_iddataprogressprogress_pendingaliven_callsrun_timeasyncior!signal)selfr(r)r*r+s `/Users/admin/workspace/ai/PDFMathTranslate/myenv/lib/python3.13/site-packages/gradio/queueing.py__init__Event.__init__/s}::<##!-!9   //04 04 &+    mmo c4URRS:H$)Nstream)r) connectionr5s r6 streamingEvent.streamingDsww!!X--r9cUR(d [S5eURRcgURURR:$)Nz6Cannot access if_finished during a non-streaming eventF)r> ValueErrorr) time_limitr2r=s r6 is_finishedEvent.is_finishedHsA~~UV V 77   %}} 2 222r9) r'r0r,r-r)r1r.r/r*r2r(r4r+N)r( str | Noner)rr*fastapi.Requestr+rE) __name__ __module__ __qualname____firstlineno__r7propertyr>rC__static_attributes__r9r6r!r!.sU& & &! &  &*..33r9r!c\rSrSrSSjrSrg) EventQueueQc`/UlXlX lSUl[ [ 5UlgNr)queuer,concurrency_limitcurrent_concurrencyrsetstart_times_per_fn)r5r,rTs r6r7EventQueue.__init__Rs."$ ,!2#$ JU K r9)r,rTrUrSrWN)r,strrT int | None)rGrHrIrJr7rLrMr9r6rOrOQs r9rOc$\rSrSrSrSSjrSrg) ProcessTime\c.SUlSUlSUlgrR process_timecountavg_timer=s r6r7ProcessTime.__init__]s  r9cU=RU- slU=RS- slURUR- Ulg)Nr_)r5times r6addProcessTime.addbs6 T! a ))DJJ6 r9)rbrar`N)rffloat)rGrHrIrJr7rgrLrMr9r6r\r\\s  7r9r\c\rSrSrSS SjjrSrS!SjrSrS"SjrS#Sjr Sr S$S jr S r S%S jr S&S jrS'S jrS(SjrS(SjrS)SjrS*S+SjjrSSS.S,SjjrS(SjrS-S.SjjrS/Sjr\S0Sj5r\S1Sj5r\S2Sj5r\S3Sj5rS4SjrS5SjrSrg)6rhc|[S5Ul0Ul0Ul[ 5Ul0UlSUlX lX0l /Ul [ 5Ul SUl [[5UlXlSUlSUlX@lXPl/UlUR-U5Ul0Ulg)NiFg?g?)rpending_messages_per_sessionpending_event_ids_sessionevent_ids_to_eventsrpending_message_lockevent_queue_per_concurrency_idstoppedmax_thread_countupdate_intervals active_jobs delete_lock server_apprr\process_time_per_fn live_updatessleep_when_freeprogress_update_sleep_when_freemax_sizeblocks_asyncio_tasks_resolve_concurrency_limitdefault_concurrency_limitevent_analytics)r5ryconcurrency_countrtr|r}rs r6r7Queue.__init__is TN )?A&57 $1O!EG+ 1 057(?LW M  )#/2,  24)-)H)H %* &JLr9cS/UR-Ul[UR5 [UR5 UR (d[UR 5 ggN)rsrurstart_processingstart_progress_updatesrynotify_clientsr=s r6start Queue.startsO 6D$9$99t445t::;  "4#6#6 7!r9c*URnURS:Xa URnO URnX R;a[ X#5URU'gUb3URUnURbX4R:aX4lggg)Ndefault)r,rTrrqrO)r5block_fnr,rTexisting_event_queues r6create_event_queue_for_fnQueue.create_event_queue_for_fns!00  % % 2 $ > >  ( : :  !D!D DBLCD / / ?  )#'#F#F~#V $66>$'M'MM9J6N *r9cSUlg)NT)rrr=s r6close Queue.closes  r9cUR(dgURUlURURnUR U5 gr)r0r'event_idrmr( put_nowait)r5event event_messagemessagess r6 send_messageQueue.send_messages> {{ !& 44U5G5GHM*r9cUS:waU$[RRS5=n(a UR5S:Xag[ U5$g)a Handles the logic of resolving the default_concurrency_limit as this can be specified via a combination of the `default_concurrency_limit` parameter of the `Blocks.queue()` or the `GRADIO_DEFAULT_CONCURRENCY_LIMIT` environment variable. The parameter in `Blocks.queue()` takes precedence over the environment variable. Parameters: default_concurrency_limit: The default concurrency limit, as specified by a user in `Blocks.queu()`. not_set GRADIO_DEFAULT_CONCURRENCY_LIMITnoneNre)osenvirongetlowerint)r5rdefault_concurrency_limit_envs r6r Queue._resolve_concurrency_limitsW % 1, ,,.JJNN .-  ( -224>899r9c|SnURR5HnU[UR5- nM U$rR)rqvalueslenrS)r5 total_len event_queues r6__len__ Queue.__len__s< >>EEGK [../ /IHr9c@# URcgURb7[U5UR:aSSURS[U5S34$UR(aGURR URnUR RURnO#URRURn[R"URSU5nURU5 [URUUU5nXl URcURUlURIShvN URUR;a![5URUR'URUR ;a![#5UR UR'SSS5IShvN UR URR%UR&5 X`R(UR&'UR*UR,nUR0R3U5 [4R4"5SSUR6URS.UR8UR&'UR;UR,[UR05S - 5 S UR&4$GNGN !,IShvN (df  GN#=f![.an[/S5UeSnAff=f7f) N)FzNo function index provided.FzQueue is full. Max size is z and size is .zEvent not found in queue. If you are deploying this Gradio app with multiple replicas, please enable stickiness to ensure that all requests from the same user are routed to the same instance.queued)rfstatusr`functionr(reT)fn_indexr|rr(r} state_holder blocks_configfnsr get_fnrr!r-rprm ThreadQueuernrVrgr'rorqr,KeyErrorrSappendrfapi_namerbroadcast_estimations) r5bodyr*r+ session_stater)rres r6push Queue.pushs == 7 == $Tdmm)C-dmm_M#d)TUV     KK44T5F5FGM,,00?B/B    T4 8 &&r*             $ % 2 2D ,,,  (I(IIGR}11$2C2CD  (F(FFDGE..t/@/@A -, &&t'8'89==eiiH.3  + ==e>R>RSK   'IIK   -- + UYY' ""5#7#7[=N=N9ORS9STUYY/-,,, R  soE LKLA7K% LK"AL%L>B"L"L%K=+K. , K=8L L LLLcXURHnUR5 M /Ulgr)r~cancel)r5tasks r6_cancel_asyncio_tasksQueue._cancel_asyncio_tasks s#''D KKM( r9cXlgr)rw)r5apps r6set_server_appQueue.set_server_appsr9cDSnURH nUcMUS- nM U$Nrre)ru)r5raworkers r6get_active_worker_countQueue.get_active_worker_counts-&&F! ' r9c[URR55n[R"U5 UHnURUn[ UR 5(dM.URbURUR:dMWUR SnURnU/nURnU(aOUUR SSVs/sH!nURUR:XdMUPM# snSURS- - nUHnUR RU5 M XgU4s $ gs snfr) listrqkeysrandomshufflerrSrTrUr)batchmax_batch_sizeremove) r5concurrency_idsr,r first_eventreventsrrs r6 get_eventsQueue.get_eventss)tBBGGIJ'-N==nMK;$$%%--522[5R5RR)//2 &>>% %0%6%6qr%:%:E 88{~~5%:4//!3 55F $E%%,,U3$n44).s E8EcV# UR(Gd6[U5S:Xa*[R"UR5IShvN MKSUR ;a*[R"UR5IShvN MUR IShvN UR5nSSS5IShvN W(GaJUup#nX R UR RS5'URUnU=RS- sl [R"5nURUSRRU5 UHnSURUR S'M! [#UR$X#U5n['UUSR(USRR USR U5 UR*R-U5 UR.(aUR1U5 O([R"UR5IShvN UR(dGM6SUlUR35 gGNGNGNGN!,IShvN (df  GN=fNW!SUlUR35 f=f7f)Nrre processingrT)rrrr3sleeprzrurvrindexrqrUrfrWr)rgrr'rprocess_eventsrr(r~rryrr) r5 event_batchrrr,r start_timerprocess_event_tasks r6rQueue.start_processing1s) )lllt9>!--(<(<===t///!--(<(<=== +++"&//"3K,+4?1F>EK$$T%5%5%;%;D%AB"&"E"En"UK33q83!%J226!9<<@DDZP!'DP,,UYY7A"()?++VJ*&"*q ..q ((q  ''../AB((22>B!--(<(<===KlllN DL  & & (M>>,+++6>DL  & & (sJ)AJ I$ 9J I'J I*J I0. J 9I-:E9J 3J 4J J)$J 'J *J -J 0J6I9 7 J J J&&J)c$# UR(dURVVs/sHocMUHo"PM M nnn[U5S:Xa*[R"UR 5IShvN MuUHKnUR (dMUR(dM)SUlURXDR5 MM [R"UR 5IShvN UR(dMggs snnfNN!7f)aH Because progress updates can be very frequent, we do not necessarily want to send a message per update. Rather, we check for progress updates at regular intervals, and send a message if there is a pending update. Consecutive progress updates between sends will overwrite each other so only the most recent update will be sent. NrF) rrrurr3rr{r/r.r)r5jobevtrrs r6rQueue.start_progress_updates]s ,,%)%5%5X%5ccTWScTWc%5FX6{ammD$H$HIII)))ennn-2E*%%e^^< -- D DE E E,,,XJ FsE!DDD5D1D 2DD#A D,D-D DDc RUcgURHnUcMUHnURU:XdM/nUHSn[URURUR UR URS9nURU5 MU [US9UlSUl M M g)N)rlengthunitr.desc) progress_dataT) rur'rrrrr.rrrr/)r5r iterablesrrriterable progress_units r6 set_progressQueue.set_progressqs   ##C{77h&8:M$-(4"*..#+??!)%-%6%6!) ) &,,];%.$3#OCL+/C($r9c URVVs/sHowcMUHoPM M n nnU H3n U RU:XdM[UUUUUS9n URX5 M5 gs snnf)N)logleveldurationvisibletitle)rur'rr) r5rrrrrrrrrr log_messages r6rQueue.log_messagesq"&!1!1T!1##PS#PS#!1TEyyH$(%#  !!%5Us A&A&N)r(rcv# URH>nU(dM UH,nURU:XdURU:XdM%SUlM. M@ URIShvN /nUR R 5HInURH6nURU:XdURU:XdM%URU5 M8 MK UH5nUR URRRU5 M7 SSS5IShvN gNN!,IShvN (df  g=f7f)NF) rur(r'r0rvrqrrSrr,r)r5r(rjob_setrevents_to_removerrs r6 clean_eventsQueue.clean_eventss''Gw"C''<7377h;N$) #( ###,. #BBIIK (..E))\9UYY(=R(//6/ L *33E4H4HIOOVV*$#####sZD9#D9D9!D"D9%A D6AD D9DD9D9D6%D( & D62D9c# UR(do[R"UR5IShvN [ U5S:a$UR HnUR U5 M UR(dMnggNL7f)zA Notify clients about events statuses in the queue periodically. Nr)rrr3rrtrrqr)r5r,s r6rQueue.notify_clientss^,,-- 5 56 6 64y1}&*&I&IN..~>'J,,, 6s5BBABBc SnURUnSnURUR:Xa/nURR 5HoupxXpR ;aSn O[UR S:XaUR=(d Sn OUR URn UUV s/sHoU -PM sn - nMq Ub<[U5S:a-[U5n [U [R"5- S5n[UR5HupU RUR ;a#UR U RROSnUb Ub UbX-U-OSnUbX:a-UR!U [#X[UR5S95 URcSnMUbAUb>XR- nU R$(aU=(d SUR- nUU- nMSnM gs sn f)Nrr;)rankrank_eta queue_size)rqrUrTrWitemsrxr<rBrbrminmaxrf enumeraterSr)rrr>)r5r,after wait_so_farrtime_till_available_workerexpected_end_timesr) start_timesr`rtime_of_first_completionrrprocess_time_for_fnrdeltas r6rQueue.broadcast_estimationss 99.I 12"  * *k.K.K K!# #.#A#A#G#G#I55515.==H,#%==#5AL#'#;#;B#?#H#HL"@K'@K*- '"$J*5#>P:QTU:U+./A+B(-0,tyy{:A.*%[%6%67KD88t777((2;; '2+.:$14NN } !!%![EVEVAW ,,4 (-@-L+.K.KK??27a#556Eu$ " M8's&G8c&[[U5S9$)N)r)rrr=s r6 get_statusQueue.get_statuss 4y  r9cT# URR5IShvN gN7f)Nr4)r4wait)rs r6wait_for_eventQueue.wait_for_events#ll!!! "s (&(cL# [R"U5IShvN gN7f)Ntimeout)r3r)rs r6r Queue.timeout smmG$$$ %s $"$c# [R"[RU55n[R"[R U55n[R "X#/[R S9IShvN upEUVs/sHofR5PM nnURR5 [[SUS5$NUs snf7f)N return_when)r4rr) r3 create_taskrrrrFIRST_COMPLETEDresultr4clearrr)rrt1t2done_ds r6wait_for_event_or_timeoutQueue.wait_for_event_or_timeouts !5!5e!< =  w!7 8 H//  %))Dq D) G/0$q'::  *s$A:C<C= CC 3CCc # /n[XSS9H=up4UR[R"[R X4555 M? [R "U[RS9IShvN upVUVs/sHowR5PM nn/n/n [XPSS9H/upU S:XaURU5 MU RU5 M1 X4$Nis snf7f)NF)strictrr4) ziprr3r!rr*r ALL_COMPLETEDr#) rtimeoutstasksrrr'r(r) awake_events closed_eventsr#s r6wait_for_batchQueue.wait_for_batchs!&5ANE LL##E$C$CE$ST B --  %))Dq D)   eS9nSn[@RB"5n[6RD"U U U UUS9IShvN n[@RB"5nUU- nSnUHBnU=RFUU- - sl#URH(dM.URJ(+US'MD U(Ga>URcSS5(Ga&UnUnU(GaURcSS5(Ga[@RB"5nUnUnUHnURU[eURH(d[fRhO[fRjUUSLURl(dSO/URH(a[o[pURl5U- OSS95 M UVs/sHowR(dMUPM nnU(dURUSRnU=RS-sl URUn X9;aU RU5 SURURRU5'UHnnURUR 5IShvN Xt;a'U(aSOSUR"UR S'MRSUR"UR S'Mp g[@RB"5nUSRH(au[rRuU[o[vURl=(d S5U- /[yU5-5IShvN unnUHnURU[aUS S95 M U(dGO[o[zUSR$5n U(aQ[-[/UVs/sH,nUR$(dMUR$R$PM. snS S065U l[6RD"U U U UUS9IShvN n[@RB"5nUHBnU=RFUU- - sl#URH(dM.URJ(+US'MD U(aURcSS5(aGMU(aS nUnOGSnU=(d UnUU RY5RZ5n[\R^"U5 UHnURU[aUUS95 M OU(a[|R~"U5n[U5HZunnU(a/SU;a)[-[/URcS5S S065UUS'USLnURU[aUUS95 M\ [@R@"5nUbkUSRH(dUU- OUnURUSRRU5 UHnUUR"UR S'M! URUSRnU=RS-sl URUn X9;aU RU5 SURURRU5'UHnnURUR 5IShvN Xt;a'U(aSOSUR"UR S'MRSUR"UR S'Mp g![a GNf=fGN![a GNf=fs snfGN![4an[MU[N5(aURP(a[RRT"5 SnUnUHhn[WUU RY5RZ5n[\R^"U5 URU[aUURcSS5SS95 Mj SnAGN-SnAff=fs snf![a GNf=fGNGNs snfGN ![4aJn[MU[N5(aURP(a[RRT"5 SnUnSnAGNSnAff=f![4aFn[MU[N5(aURP(a[RRT"5 SnAGNSnAff=f![a GNBf=fGN#!URUSRnU=RS-sl URUn X9;aU RU5 SURURRU5'O![a Of=fUHonURUR 5IShvN Xt;a'U(aSOSUR"UR S'MSSUR"UR S'Mq f=f7f)NrF)etaresuccessfailedr cancelledz No event datar-TServer app has not been set.)rr)r+r*z /queue/join)r* route_path root_path)rr gr_requestr)r= is_generatingrr )outputrr8)msgr@r8rB)r@r8r-r`)Br)r0rrrxrbrrqr,rUrWrrurrAreset_iteratorsr'rr-r+rr*rr.batchedrw Exceptionr compile_gr_request get_root_urlrr=rf monotoniccall_process_apir2r>rC isinstancer print_exception traceback print_excr get_blocks show_errorr send_errorrrrrprocess_generatingprocess_streamingrBrrrr4rirr copydeepcopyr rg)r5rr begin_timer2r)r8rrrrr+rr>r=first_iterationrresponseenderrrcontent old_responseold_errr3 closed_eventr@errorend_timers r6rQueue.process_events4s8 %' AY\\f L;;;%%,!%=%==!% 8 8 < E E!%!''.  @==fQi>V>VWK  + +q 0 +%88>D| 11ay))H16F1IMMDDM %ay00  7=Lve/%**//vL$ &ay00 # //C{ >??$77! J <<+ ++#00 (\5--I  O (!,!=!=)' "nn&"%+)ENNcEk1N8=8I8I4I1**HLL%@@' 8<<#G#G NN,E#+L!G!-))!4',%2$D$D%2%D%D'3(4D(@')}},0$)??&*#r}}%=%O%) ". 8D#S|e{{E|L#S'|==fQi>V>VWK  + +q 0 +%88 $ 1 1$0$;/7%&!"1> ,!#$7a9M9MN (, #6<&&5;E+0::)8 5;&&!" ,1 !" )DI*5)E)E #!%'1!&/ *$#nn.%1E!NNcEk9N$@E@Q@QV>VWK  + +q 0 +%88V>VWK  + +q 0 +%88(o87q>8 pq>p&q>+p. ,Aq>>rc6# URnUc [S5eXR;agURIShvN URU URR U5 SSS5IShvN gN=N!,IShvN (df  g=f7f)Nr;)rwrE iteratorslockiterators_to_resetrg)r5rrs r6rCQueue.reset_iterators"sqoo ;:; ; == ( 888 h'  " " & &x 08 888 sE;BA;B)A?* B5A=6B=B?BB  BB)r~rur}rrvrrorqryr|rsrnrprmrxr{rwrzrrrt)r) ryboolrrrtrir|rZr}rrint | None | Literal['not_set'])rr)rr!rr)rrgreturnrZ)rr r*rFr+rErhztuple[bool, str])rz routes.App)rhr)rhz$tuple[list[Event], bool, str] | None)rhNone)rrYrzlist[TrackedIterable] | None) T) rrYrrYrrYrz%Literal['info', 'warning', 'success']rz float | Nonerrf)r(rErrErhrir)r,rYr rZrhri)rhr)rr!rhrY)rrirhrY)rr!rrirhzLiteral['signal', 'timeout'])r list[Event]r0z list[float]rhztuple[list[Event], list[Event]])rrkrrfrUrirhri)rrY) rGrHrIrJr7rrrrrrrrrrrrrrrrrrr staticmethodrrr*r4rrCrLrMr9r6rrhs@FO"L"L"L "L  "L  "L$C"LH8K* + +$ +)H , 3'32A3MW3 3j! 52*)XF(0000>"$666 6 5 6  66,-1)rys"  #&//22$*)   3 3 3F   7 7E E r9