ph'hSSKrSSKrSSKJrJrJr "SS5rS\RS\4SjrSr g) N)AnyCallable Coroutinec \rSrSrSrSrSrSrS\S\ 4Sjr S \S\ 4S jr S \S \ S \ \ \ \ 444S jrS\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. cbSUl/Ul[R"5UlSUlg)NF) _next_timer _event_loops threadingLock_lock_stoppedselfs J/home/james-whalen/.local/lib/python3.13/site-packages/redis/background.py__init__BackgroundScheduler.__init__ s'^^%  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 r,r-_call_later_recurringr/)rr4r#r'r r0s r run_recurring!BackgroundScheduler.run_recurring=sZZ}}Z %%' ZZ    $ $T *!!.22HNN   ZZr3coro.c ^^^^^# TR TR(a SSS5 gSSS5 [R"5m[ TU/UQ76mUUUUU4SjmTR TT5Tlg!,(df  NR=f7f)z 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. Nc>TR TR(a SSS5 gSSS5 T"5 TRTT5Tlg!,(df  N-=frrr call_laterr )r4r rtickwrappedsrr>5BackgroundScheduler.run_recurring_async..tick`sE==  I#x>D  s A A )rrr)get_running_loop_async_to_sync_wrapperr=r )rr4r9r'r r>r?s`` @@@rrun_recurring_async'BackgroundScheduler.run_recurring_asyncRsoZZ}}Z'')(t;d; ? ? ??8T:#Zs! BA= BA B= B Br cUR UR(a SSS5 gSSS5 UR"X#/UQ76Ulg!,(df  N'=frr<)rr r"r#r's rr.BackgroundScheduler._call_laterlsDZZ}}Z ??5BTBZs A  AcUR UR(a SSS5 gSSS5 UR"XURXU/UQ76 g!,(df  N/=fr)rrr._execute_recurringrr r4r#r's rr6)BackgroundScheduler._call_later_recurringtsSZZ}}Z  D33TX PT Zs A A!cxUR 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)rr Exceptionr.rHrIs rrH&BackgroundScheduler._execute_recurringsZZ}}Z  dO ZZ}}Z  D33TX PT Z    Zs(B BB+ B B('B(+ B9)r rr rN)__name__ __module__ __qualname____firstlineno____doc__rrrfloatrr1r7rrrCr)AbstractEventLoopr.r6rH__static_attributes__rrrrs &(ex*ex*;;%-c9S#s]3K.K%L;4C--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: return_exceptionsTN) r)set_event_loop call_soon run_forever all_tasksrrun_until_completegatherrLclose)rWrXr'pendingtasks rr-r-s( :&9D9  '' 3G    ) )@4@             '' 3G    ) )@4@        J   sfCAB!! B.+B1-B..B11CEADD> D*'D>)D**D>-E>EEc ^^^^UUUU4SjnU$)a Wraps an asynchronous function so it can be used with loop.call_later. :param loop: The event loop in which the coroutine will be executed. :param coro_func: The coroutine function to wrap. :param args: Positional arguments to pass to the coroutine function. :param kwargs: Keyword arguments to pass to the coroutine function. :return: A regular function suitable for loop.call_later. c<>[R"T"T0TD6TS9 g)N)r )r) ensure_future)r' coro_funckwargsr srr?'_async_to_sync_wrapper..wrappedsi88tDrrV)r rgr'rhr?s```` rrBrBsEE Nr) r)r typingrrrrrTr-rBrVrrrks>++V V r))9A<r