1i'fddlZddlZddlmZmZmZGddZdejdefdZdZ y) N)AnyCallable Coroutinec eZdZdZdZdZdZdedefdZ dedefd Z ded ed e e e e fffd Z d ejdedefdZd ejdedefdZd ejdedefdZy)BackgroundSchedulerzf Schedules background tasks execution either in separate thread or in the running event loop. c`d|_g|_tj|_d|_y)NF) _next_timer _event_loops threadingLock_lock_stoppedselfs Z/mnt/e/genesis-system/.venvs/voice-bridge/lib/python3.12/site-packages/redis/background.py__init__zBackgroundScheduler.__init__ s'^^%  c$|jyN)stoprs r__del__zBackgroundScheduler.__del__s  rc|j5|jr dddyd|_|jr!|jjd|_|jD].}|j s|j |j0|jjdddy#1swYyxYw)zB Stop all scheduled tasks and clean up resources. NT) r rr cancelr is_runningcall_soon_threadsaferclear)rloops rrzBackgroundScheduler.stopsZZ &}} & &!DM  '')#' )) 9??$--dii8 9    # # % & & &sB8AB887B88Cdelaycallbackc|j5|jr dddy dddtj}|j5|jj |dddt jt||j||g|d}|jy#1swYxYw#1swYSxYw)zI Runs callable task once after certain delay in seconds. NTtargetargsdaemon) r rasyncionew_event_loopr appendr Thread_start_event_loop_in_thread _call_laterstart)rrrr#rthreads rrun_oncezBackgroundScheduler.run_once(sZZ }}    %%' ZZ +    $ $T * +!!.((%ADA      + +B/ B;/B8;Cintervalc|j5|jr dddy dddtj}|j5|jj |dddt jt||j||g|d}|jy#1swYxYw#1swYSxYw)zN Runs recurring callable task with given interval in seconds. NTr!) r rr%r&r r'r r(r)_call_later_recurringr+)rr/rr#rr,s r run_recurringz!BackgroundScheduler.run_recurring=sZZ }}    %%' ZZ +    $ $T * +!!.22HhNN      + +r.coro.cKj5jr dddy dddtjt |g|fdj _y#1swYKxYww)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. Ncj5jr dddy dddj_y#1swY(xYwrr r call_laterr )r/rrtickwrappedsrr8z5BackgroundScheduler.run_recurring_async..tick`sP ==     I#x>D    s A  A)r rr%get_running_loop_async_to_sync_wrapperr7r )rr/r3r#rr8r9s`` @@@rrun_recurring_asyncz'BackgroundScheduler.run_recurring_asyncRs{ZZ }}   '')(t;d; ? ? ??8T:#  s! BA6 BA B6A?;Brc|j5|jr dddy ddd|j||g||_y#1swY#xYwrr6)rrrrr#s rr*zBackgroundScheduler._call_laterlsSZZ }}   +4??5(BTB  s AAc|j5|jr dddy ddd|j|||j|||g|y#1swY,xYwr)r rr*_execute_recurringrrr/rr#s rr1z)BackgroundScheduler._call_later_recurringtsdZZ }}     (D33T8X PT   s AAcR|j5|jr dddy ddd |||j5|jr dddy ddd|j|||j|||g|y#1swY^xYw#t$rYfwxYw#1swYGxYw)zR Executes recurring callable task with given interval in seconds. N)r r Exceptionr*r?r@s rr?z&BackgroundScheduler._execute_recurringsZZ }}     dO ZZ }}     (D33T8X PT         s'BBBB  BBB&N)__name__ __module__ __qualname____doc__rrrfloatrr-r2rrr<r%AbstractEventLoopr*r1r?rrrrs &(ex*ex*;;%-c9S#s]3K.K%L;4C--C6;CGOC  ''       ''    rr event_loop call_soon_cbc tj||j||g| |j tj|}|D]}|j |j tj|ddi|jy#t$rYwxYw#|jwxYw# tj|}|D]}|j |j tj|ddin#t$rYnwxYw|jw#|jwxYwxYw)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_completegatherrBclose)rJrKr#pendingtasks rr)r)s6 :&Jz9D9  '' 3G     ) )@4@             '' 3G     ) )@4@        J   sfCAB B)&B,(B))B,,B>E ADD4 D D4D  D4#E 4EE cfd}|S)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@tjiy)N)r)r% ensure_future)r# coro_funckwargsrsrr9z'_async_to_sync_wrapper..wrappedsi88tDrrI)rrZr#r[r9s```` rr;r;sE Nr) r%r typingrrrrrHr)r;rIrrr]s>++V V r))9A<r