ng\jVBjSSKrSSKrSSKrSSKJrJrJr "SS5rS\RS\4Sjr g)N)AnyCallable Coroutinec \rSrSrSrSrSrSrS\S\ 4Sjr S \S\ 4S jr S \S \ S \ \ \ \ 444S jrSS.S \ S \ \ \ \ 44S\S-S\ 4SjjrS \ S \ \ \ \ 44SS4SjrSS\4SjjrSrS\R(S \S \ S \ \ \ \ 444SjrS\R(S \S \ S \ \ \ \ 444SjrS \S \ S \ \ \ \ 444SjrS\R(S\S\ 4SjrS\R(S \S\ 4SjrS\R(S \S\ 4SjrSrg) BackgroundSchedulerz^ Schedules background tasks execution either in separate thread or in the running event loop. cSUl/Ul[R"5UlSUlSUlSUl[R"5Ul g)NF) _next_timer _event_loops threadingLock_lock_stopped_health_check_loop_health_check_threadEvent_health_check_loop_readyselfs K/home/edenadmin/noVNC/venv/lib/python3.13/site-packages/redis/background.py__init__BackgroundScheduler.__init__ sF^^%  DH=A!(1(9%c$UR5 gN)stoprs r__del__BackgroundScheduler.__del__s  rcUR UR(a SSS5 gSUlUR(a!URR5 SUlURH5nUR 5(dMUR UR5 M7 URR5 SSS5 g!,(df  g=f)z2 Stop all scheduled tasks and clean up resources. NT) rrr cancelr is_runningcall_soon_threadsaferclear)rloops rrBackgroundScheduler.stopsZZ}}Z!DM  '')#' ))??$$--dii8*    # # %ZZsC AC 9C  CdelaycallbackcUR UR(a SSS5 gSSS5 [R"5nUR URR U5 SSS5 [ R"[X@RX/UQ7SS9nUR5 g!,(df  N=f!,(df  NY=f)z9 Runs callable task once after certain delay in seconds. NTtargetargsdaemon) rrasyncionew_event_loopr appendr Thread_start_event_loop_in_thread _call_laterstart)rr&r'r+r$threads rrun_onceBackgroundScheduler.run_once.sZZ}}Z %%' ZZ    $ $T *!!.((%ADA   ZZB1C1 B? CintervalcUR UR(a SSS5 gSSS5 [R"5nUR URR U5 SSS5 [ R"[X@RX/UQ7SS9nUR5 g!,(df  N=f!,(df  NY=f)z> Runs recurring callable task with given interval in seconds. NTr)) rrr-r.r r/r r0r1_call_later_recurringr3)rr8r'r+r$r4s r run_recurring!BackgroundScheduler.run_recurringCsZZ}}Z %%' ZZ    $ $T *!!.22HNN   ZZr7coro.cJUR UR(a SSS5 gSSS5 UR5 UR URnSSS5 WR"UR XAU/UQ76 g!,(df  N_=f!,(df  N?=f)z Runs recurring coroutine with given interval in seconds in a background thread. Uses a shared event loop to ensure connection pools remain valid across calls. This is useful for sync code that needs to run async health checks. N)rr_ensure_health_check_looprr"_call_later_recurring_coro)rr8r=r+r$s rrun_recurring_coro&BackgroundScheduler.run_recurring_coroXs~ZZ}}Z &&( ZZ**D !!  + +TT DH ZZsB B B B"g$@timeoutrDNreturncUR UR(a [S5eSSS5 UR5 UR URnSSS5 [ R "U"U6W5nURUS9$!,(df  Ni=f!,(df  NI=f![a UR5 ef=f)a Runs a coroutine synchronously and returns its result. Uses the shared health check event loop to ensure connection pools created here remain valid for subsequent recurring health checks. This is useful for running the initial health check before starting recurring checks. Args: coro: Coroutine function to execute *args: Arguments to pass to the coroutine timeout: Maximum seconds to wait for the result. None means wait forever. Default is 10 seconds to avoid blocking indefinitely if the event loop is busy with long-running health checks. Returns: The result of the coroutine Raises: TimeoutError: If the coroutine doesn't complete within timeout Any exception raised by the coroutine zScheduler is stoppedNrC) rr RuntimeErrorr?rr-run_coroutine_threadsaferesult TimeoutErrorr )rr=rDr+r$futures r run_coro_sync!BackgroundScheduler.run_coro_syncps:ZZ}}"#9:: &&( ZZ**D11$+tD ===1 1ZZ  MMO  s#B B?B0 B B-0C cUR UR(a SSS5 gSSS5 UR5 UR URnSSS5 S[R 4Sjn[R "U"U6W5nURU5 g!,(df  N=f!,(df  N`=f)ai Schedule a coroutine for execution on the shared health check loop without waiting for the result. Exceptions are logged but not raised. This is useful for HALF_OPEN recovery health checks that need to run on the same event loop where connection pools were created. Args: coro: Coroutine function to execute *args: Arguments to pass to the coroutine NrKcUR5(a*[R"[5R S5 gUR 5b7[R"[5R SUR 5S9 gg)z&Log any exceptions from the coroutine.z#Fire-and-forget coroutine cancelledNz*Fire-and-forget coroutine raised exceptionexc_info) cancelledlogging getLogger__name__debug exception)rKs r on_completeABackgroundScheduler.run_coro_fire_and_forget..on_completesl!!!!(+112WX!!#/!!(+11@#--/20r)rrr?rr-FuturerHadd_done_callback)rr=r+r$rXrKs rrun_coro_fire_and_forget,BackgroundScheduler.run_coro_fire_and_forgetsZZ}}Z &&( ZZ**D  11$+tD  --ZZsB$ B5$ B25 CcURR5(aKUR URb)URR 5(a SSS5 gSSS5 UR URb)URR 5(a SSS5 gURR 5 [ R"5UlURRUR5 [R"URSS9Ul URR5 URRUS9(d]URnSUlX R;aURR!U5 UR#5 ['SUS35eSSS5 g!,(df  GNn=f![$a N7f=f!,(df  g=f)z Ensure the shared health check loop and thread are running. Args: timeout: Maximum seconds to wait for the loop to start. Raises: RuntimeError: If the loop fails to start within the timeout. NT)r*r,rCz/Health check event loop failed to start within z seconds)ris_setrrr!r#r-r.r r/r r0_run_health_check_looprr3waitremoveclose ExceptionrG)rrD failed_loops rr?-BackgroundScheduler._ensure_health_check_loops  ( ( / / 1 1++7//::<< ZZ''3++6688 Z  ) ) / / 1'.&<&<&>D #    $ $T%<%< =)2(8(822)D %  % % + + - 0055g5F#55 *.'"3"33%%,,[9%%'#EgYhWG5ZT!GZsB.G 7.G,.C2G,!G1G, G G)&G,(G))G,, G:c [R"UR5 URRURR 5 URR 5 [R"UR5nUHnUR5 M URR[R"USS065 URR5 g![a N'f=f!URR5 f=f![R"UR5nUHnUR5 M URR[R"USS065 O![a Of=fURR5 f!URR5 f=f=f)z'Run the shared health check event loop.return_exceptionsTN) r-set_event_loopr call_soonrset run_forever all_tasksr run_until_completegatherrdrc)rpendingtasks rr`*BackgroundScheduler._run_health_check_loopsmt667 ))$*G*G*K*KL 0  # # / / 1 0!++D,C,CD#DKKM$''::NNGDtD ''--/  ''--/ 0!++D,C,CD#DKKM$''::NNGDtD  ''--/''--/shD,A(C// C<9C?;C<<C??DG A(F F4 FF4FF4G4GGr$cUR UR(a SSS5 gSSS5 UR"XURXU/UQ76 g!,(df  N/=f)z0Schedule first execution of recurring coroutine.N)rrr2_execute_recurring_coro)rr$r8r=r+s rr@.BackgroundScheduler._call_later_recurring_corosSZZ}}Z  D88$$ QU Z A A!c  ^^^^^TR TR(a SSS5 gSSS5 S[R4UUUUU4Sjjn[R"T"T65nUR U5 g!,(df  NV=f![ ai TR TR(a SSS5 gSSS5 O!,(df  O=fTR"TTTRTTT/TQ76 gf=f)z Executes recurring coroutine with given interval in seconds. Schedules next execution only after current one completes to prevent overlap. Nrqc>UR5(aOGUR5b6[R"[5R SUR5S9 TR  TR(a SSS5 gSSS5 TR"TTTRTTT/TQ76 g!,(df  N1=f).on_complete7s~~!-!!(+11;!^^-2 ==    ,,    s +B33 C) rrr-Task ensure_futurer[rdr2rt)rr$r8r=r+rXrqs````` rrt+BackgroundScheduler._execute_recurring_coro(sZZ}}Z gll  6 ((t5D  " "; /EZF ==    ,,    s;A?*B? B D&C 9D D C )DDc^^^^^^^# TR TR(a SSS5 gSSS5 [R"5mUUUU4SjmUUUU4SjmTR TT5Tlg!,(df  NM=f7f)aV Runs recurring coroutine with given interval in seconds in the current event loop. To be used only from an async context. No additional threads are created. Prevents overlapping executions by scheduling the next run only after the current one completes. Raises: RuntimeError: If called without a running event loop (programming error) Nc>TR TR(a SSS5 gSSS5 TRTT5Tlg!,(df  N&=f)zBackgroundScheduler.run_recurring_async..schedule_next{sA==  $x9OPD s A  Ac>TR TR(a SSS5 gSSS5 S[R4U4Sjjn[R"T"T65nUR U5 g!,(df  NR=f![ a2 [R"[5RSSS9 T"5 gf=f)z=Execute the coroutine and schedule next run after completion.Nrqc>UR5(aOGUR5b6[R"[5R SUR5S9 T"5 g)ryNz*Recurring async coroutine raised exceptionrP)rRrWrSrTrUrV)rqrs rrX\BackgroundScheduler.run_recurring_async..execute_and_reschedule..on_completesT>>##^^%1%%h/55D!%!16 rz,Failed to schedule recurring async coroutineTrP) rrr-r{r|r[rdrSrTrUrV)rXrqr+r=rrs rrGBackgroundScheduler.run_recurring_async..execute_and_reschedules==  ',,  ,,T4[9&&{3'( !!(+11BT2  sA7 *B7 B9CC)rrr-get_running_looprr )rr8r=r+rr$rs````@@@rrun_recurring_async'BackgroundScheduler.run_recurring_asynceslZZ}}Z'') Q Q  < ??85KL]Zs! B A: B AB : BB cUR UR(a SSS5 gSSS5 UR"X#/UQ76Ulg!,(df  N'=frr)rr$r&r'r+s rr2BackgroundScheduler._call_latersDZZ}}Z ??5BTBZs A  AcUR UR(a SSS5 gSSS5 UR"XURXU/UQ76 g!,(df  N/=fr)rrr2_execute_recurringrr$r8r'r+s rr:)BackgroundScheduler._call_later_recurringsSZZ}}Z  D33TX PT ZrvcxUR UR(a SSS5 gSSS5 U"U6 UR UR(a SSS5 gSSS5 UR"XURXU/UQ76 g!,(df  Nf=f![a Nof=f!,(df  NP=f)zB Executes recurring callable task with given interval in seconds. N)rrrdr2rrs rr&BackgroundScheduler._execute_recurringsZZ}}Z  dO ZZ}}Z  D33TX PT Z    Zs(B BB+ B B('B(+ B9)r rrrrr r)g@)rU __module__ __qualname____firstlineno____doc__rrrfloatrr5r;rrrArLr\r?r`r-AbstractEventLoopr@rtrr2r:r__static_attributes__rrrrs :&(ex*ex*  %-c9S#s]3K.K%L 8!% .sIc3m445. . .`$.S)CcM"::;$. $.L::x0.  ''    sIc3m445  ;'';;sIc3m445 ;z;M;M%-c9S#s]3K.K%L;MzC--C6;CGOC  ''       ''    rr event_loop call_soon_cbc [R"U5 UR"X/UQ76 UR5 [R"U5nUHnUR 5 M UR [R"USS065 UR5 g![a Nf=f!UR5 f=f![R"U5nUHnUR 5 M UR [R"USS065 O![a Of=fUR5 f!UR5 f=f=f)z Starts event loop in a thread and schedule callback as soon as event loop is ready. Used to be able to schedule tasks using loop.call_later. :param event_loop: :return: rhTN) r-rirjrlrmr rnrordrc)rrr+rprqs rr1r1s( :&9D9  '' 3G    ) )@4@             '' 3G    ) )@4@        J   sfCAB!! B.+B1-B..B11CEADD> D*'D>)D**D>-E>EE) r-rSr typingrrrrrr1rrrrs<++K K \))9Ar