h'dddlZddlZddlmZmZmZGddZdejdefdZdZ dS) N)AnyCallable Coroutinec eZdZdZdZdZdZdedefdZ dedefd Z ded ed e e e e fffd Z d ejdedefdZd ejdedefdZd ejdedefdZdS)BackgroundSchedulerzf Schedules background tasks execution either in separate thread or in the running event loop. c`d|_g|_tj|_d|_dS)NF) _next_timer _event_loops threadingLock_lock_stoppedselfs P/var/www/html/auto_sub_bot/venv/lib/python3.11/site-packages/redis/background.py__init__zBackgroundScheduler.__init__ s,^%%  c.|dSN)stoprs r__del__zBackgroundScheduler.__del__s rcn|j5|jr ddddSd|_|jr |jd|_|jD]0}|r||j1|jddddS#1swxYwYdS)zB Stop all scheduled tasks and clean up resources. NT) r rr cancelr is_runningcall_soon_threadsaferclear)rloops rrzBackgroundScheduler.stops(Z & &}  & & & & & & & &!DM ( '')))#' ) 9 9??$$9--di888   # # % % % & & & & & & & & & & & & & & & & & &s B*A?B**B.1B.delaycallbackc|j5|jr ddddS dddn #1swxYwYtj}|j5|j|dddn #1swxYwYt jt||j ||g|Rd}| dS)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(shZ  }                          %'' Z + +   $ $T * * * + + + + + + + + + + + + + + +!.(%ADAA      +//A77A;>A;intervalc|j5|jr ddddS dddn #1swxYwYtj}|j5|j|dddn #1swxYwYt jt||j ||g|Rd}| dS)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=shZ  }                          %'' Z + +   $ $T * * * + + + + + + + + + + + + + + +!.2HhNNN     r.coro.cKj5jr ddddS dddn #1swxYwYtjt |g|Rfd_dS)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 ddddS dddn #1swxYwY_dSrr r call_laterr )r/rrtickwrappedsrr8z5BackgroundScheduler.run_recurring_async..tick`s  =                        GIII#x>>D   s ,00)r rr%get_running_loop_async_to_sync_wrapperr7r )rr/r3r#rr8r9s`` @@@rrun_recurring_asyncz'BackgroundScheduler.run_recurring_asyncRsZ  }                         '))(t;d;;; ? ? ? ? ? ? ? ? ? ??8T::s 266rc|j5|jr ddddS dddn #1swxYwY|j||g|R|_dSrr6)rrrrr#s rr*zBackgroundScheduler._call_laterlsZ  }                         +4?5(BTBBB +//c|j5|jr ddddS dddn #1swxYwY|j|||j|||g|RdSr)r rr*_execute_recurringrrr/rr#s rr1z)BackgroundScheduler._call_later_recurringtsZ  }                           (D3T8X PT      r>c8|j5|jr ddddS dddn #1swxYwY ||n#t$rYnwxYw|j5|jr ddddS dddn #1swxYwY|j|||j|||g|RdS)zR Executes recurring callable task with given interval in seconds. N)r r Exceptionr*r@rAs rr@z&BackgroundScheduler._execute_recurringsZ  }                           HdOOO    D Z  }                           (D3T8X PT      s- +//= A  A  A77A;>A;N)__name__ __module__ __qualname____doc__rrrfloatrr-r2rrr<r%AbstractEventLoopr*r1r@rrrrsd &&&(ex*ex*;;%-c9S#s]3K.K%L;;;;4C-C6;CGOCCCC  '          '         rr event_loop call_soon_cbc tj||j||g|R | tj|}|D]}||tj|ddin#t$rYnwxYw| dS#| wxYw# tj|}|D]}||tj|ddin#t$rYnwxYw| w#| wxYwxYw)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_completegatherrCclose)rKrLr#pendingtasks rr)r)s :&&&Jz9D9999    ' 33G    ) )@4@@        D         J       ' 33G    ) )@4@@        D        J      slC AB B2 BB2BB22C E ADE D,)E+D,,E/EEEcfd}|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@tjidS)N)r)r% ensure_future)r# coro_funckwargsrsrr9z'_async_to_sync_wrapper..wrappeds.ii888tDDDDDDrrJ)rr[r#r\r9s```` rr;r;s=EEEEEEEE Nr) r%r typingrrrrrIr)r;rJrrr^s++++++++++V V V V V V V V r)9A<r