jVBhddlZddlZddlZddlmZmZmZGddZdejdefdZ y)N)AnyCallable Coroutinec eZdZdZdZdZdZdedefdZ dedefd Z ded ed e e e e fffd Z d dd ed e e e e ffdedzde fdZd ed e e e e ffddfdZddefdZdZdej&ded ed e e e e fffdZdej&ded ed e e e e fffdZded ed e e e e fffdZdej&dedefdZdej&dedefdZdej&dedefdZy)BackgroundSchedulerzf Schedules background tasks execution either in separate thread or in the running event loop. cd|_g|_tj|_d|_d|_d|_tj|_ y)NF) _next_timer _event_loops threadingLock_lock_stopped_health_check_loop_health_check_threadEvent_health_check_loop_readyselfs Z/var/www/html/Fitness-lenito-AI-main/venv/lib/python3.12/site-packages/redis/background.py__init__zBackgroundScheduler.__init__ sF^^%  DH=A!(1(9%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}}Z!DM  '')#' ))??$--dii8*    # # %ZZsB8AB887B88Cdelaycallbackc|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)rr"r#r'r!threads rrun_oncezBackgroundScheduler.run_once.sZZ}}Z %%' ZZ    $ $T *!!.((%ADA   ZZB/ 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/)rr3r#r'r!r0s r run_recurringz!BackgroundScheduler.run_recurringCsZZ}}Z %%' ZZ    $ $T *!!.22HhNN   ZZr2coro.c.|j5|jr dddy ddd|j|j5|j}dddj|j |||g|y#1swY[xYw#1swY6xYw)a 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)r r_ensure_health_check_looprr_call_later_recurring_coro)rr3r7r'r!s rrun_recurring_coroz&BackgroundScheduler.run_recurring_coroXsZZ}}Z &&( ZZ**D "!!  + +T8T DH ZZsA? B ?B Bg$@timeoutr=Nreturnc|j5|jr td ddd|j|j5|j}dddt j ||} |j|S#1swYfxYw#1swYAxYw#t$r|jwxYw)ag 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 stoppedNr<) r r RuntimeErrorr9rr)run_coroutine_threadsaferesult TimeoutErrorr)rr7r=r'r!futures r run_coro_syncz!BackgroundScheduler.run_coro_syncps:ZZ}}"#9:: &&( ZZ**D11$+tD ===1 1ZZ  MMO  s#B  B9B# BB #B>cj|j5|jr dddy ddd|j|j5|j}ddddtj fd}t j ||}|j|y#1swYyxYw#1swYTxYw)a 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 NrDc|jr)tjtj dy|j 9tjtj d|j yy)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)rDs r on_completezABackgroundScheduler.run_coro_fire_and_forget..on_completesi!!!(+112WX!!#/!!(+11@#--/20r)r rr9rr)FuturerAadd_done_callback)rr7r'r!rPrDs rrun_coro_fire_and_forgetz,BackgroundScheduler.run_coro_fire_and_forgetsZZ}}Z &&( ZZ**D  11$+tD  --ZZsB B)B&)B2c|jjrE|j5|j$|jj r dddyddd|j5|j$|jj r dddy|jj t j|_|jj|jtj|jd|_ |jj|jj|s\|j}d|_||jvr|jj!| |j#t'd|d dddy#1swYaxYw#t$$rY1wxYw#1swYyxYw)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(r<z/Health check event loop failed to start within z seconds)ris_setr rrr r)r*r r+r r,_run_health_check_looprr/waitremoveclose Exceptionr@)rr= failed_loops rr9z-BackgroundScheduler._ensure_health_check_loops  ( ( / / 1++7//::< ZZ''3++668 Z  ) ) / / 1'.&<&<&>D #    $ $T%<%< =)2(8(822)D %  % % + + - 0055g5F#55 *.'$"3"33%%,,[9%%'#EgYhWG5ZT!GZsB(F7,(GC0GGG7G G GGGGc tj|j|jj|jj  |jj  tj|j}|D]}|j|jjtj|ddi|jjy#t$rY&wxYw#|jjwxYw# tj|j}|D]}|j|jjtj|ddin#t$rYnwxYw|jjw#|jjwxYwxYw)z'Run the shared health check event loop.return_exceptionsTN) r)set_event_loopr call_soonrset run_forever all_tasksrrun_until_completegatherrZrY)rpendingtasks rrVz*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** C63C95C66C99DGA$E?>F)? F F) F  F)G)GGr!c|j5|jr dddy ddd|j|||j|||g|y#1swY,xYw)z0Schedule first execution of recurring coroutine.N)r rr._execute_recurring_coro)rr!r3r7r's rr:z.BackgroundScheduler._call_later_recurring_corosYZZ}}Z  (D88$$ QU Z AAc j5jr dddy ddddtjffd } tj}|j |y#1swYNxYw#t $r_j5jr dddYy dddn #1swYnxYwjjgYywxYw)z Executes recurring coroutine with given interval in seconds. Schedules next execution only after current one completes to prevent overlap. Nrfcl|jrnH|j8tjtj d|jj 5jr dddy dddjjgy#1swY,xYw).on_complete7s~~!-!!(+11;!^^-2 ==  D  ,,    s 'B**B3) r rr)Task ensure_futurerRrZr.rh)rr!r3r7r'rPrfs````` rrhz+BackgroundScheduler._execute_recurring_coro(sZZ}}Z gll  6 ((t5D  " "; /EZF ==  D  ,,    s;A7 )B7BC+B:&C+1 C+:C ?)C+*C+cKj5jr dddy dddtjfdfdj _y#1swYExYww)a 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) Ncj5jr dddy dddj_y#1swY!xYw)zBackgroundScheduler.run_recurring_async..schedule_next{sA==  $x9OPD s AAcvj5jr dddy ddddtjffd } tj}|j |y#1swYJxYw#t $r4tjtjddYywxYw)z=Execute the coroutine and schedule next run after completion.Nrfc|jrnH|j8tjtj d|jy)rlNz*Recurring async coroutine raised exceptionrH)rJrOrKrLrMrN)rfrts rrPz\BackgroundScheduler.run_recurring_async..execute_and_reschedule..on_completesQ>>#^^%1%%h/55D!%!16 rz,Failed to schedule recurring async coroutineTrH) r rr)rmrnrRrZrKrLrMrN)rPrfr'r7rtrs rrszGBackgroundScheduler.run_recurring_async..execute_and_reschedules==  ',,  ,,T4[9&&{3'( !!(+11BT2  sA/)A;/A8;:B87B8)r rr)get_running_looprrr )rr3r7r'rsr!rts````@@@rrun_recurring_asyncz'BackgroundScheduler.run_recurring_asyncesbZZ}}Z'') Q < ??85KL]Zs! A>A2 A>AA>2A;7A>c|j5|jr dddy ddd|j||g||_y#1swY#xYwrrq)rr!r"r#r's rr.zBackgroundScheduler._call_latersHZZ}}Z+4??5(BTBZs AAc|j5|jr dddy ddd|j|||j|||g|y#1swY,xYwr)r rr._execute_recurringrr!r3r#r's rr5z)BackgroundScheduler._call_later_recurringsYZZ}}Z  (D33T8X PT ZricR|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 rrZr.r{r|s rr{z&BackgroundScheduler._execute_recurringsZZ}}Z  dO ZZ}}Z  (D33T8X PT Z    Zs'BBBB  BBB&)g@)rM __module__ __qualname____doc__rrrfloatrr1r6rrr;rErSr9rVr)AbstractEventLoopr:rhrxr.r5r{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 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: r]TN) r)r^r_rarbrrcrdrZrY)rrr'rerfs rr-r-s, :&Jz9D9  '' 3G    ) )@4@             '' 3G    ) )@4@        J   sfCAB B)&B,(B))B,,B>E ADD4 D D4D  D4#E 4EE ) r)rKr typingrrrrrr-rrrrs<++K K \))9Ar