∋dUddlmZddlZddlZddlZddlZddlZddlZgdZiZ de d<e ej e ej ejdkZejdkZejdkZd Zd Zejd krdd lmZdSddlZddlZdd lmZmZddlmZddlmZddlm Z GddZdS)) annotationsN) logging_namesPeriodicCallback to_thread randbyteszdict[str | int, int | str]rlinuxdarwinwin32c\tjdtdtj|i|S)Nz_to_thread is deprecated and will be removed in a future release; use asyncio.to_thread instead. stacklevel)warningswarnDeprecationWarningasynciorargskwargss 9lib/python3.11/site-packages/distributed/compatibility.pyrrs< Mi  d -f - --c\tjdtdtj|i|S)Nz^randbytes is deprecated and will be removed in a future release; use random.randbytes instead.r r )rrrrandomrrs rrrs< Mh  T ,V , ,,r)r rr)r) AwaitableCallable) isawaitable)IOLoop)app_logcNeZdZdZ ddd Zdd Zdd ZddZddZddZ ddZ dS)raSchedules the given callback to be called periodically. The callback is called every ``callback_time`` milliseconds when ``callback_time`` is a float. Note that the timeout is given in milliseconds, while most other time-related functions in Tornado use seconds. ``callback_time`` may alternatively be given as a `datetime.timedelta` object. If ``jitter`` is specified, each callback time will be randomly selected within a window of ``jitter * callback_time`` milliseconds. Jitter can be used to reduce alignment of events with similar periods. A jitter of 0.1 means allowing a 10% variation in callback time. The window is centered on ``callback_time`` so the total number of calls within a given interval should not be significantly affected by adding jitter. If the callback runs for longer than ``callback_time`` milliseconds, subsequent invocations will be skipped to get back on schedule. `start` must be called after the `PeriodicCallback` is created. .. versionchanged:: 5.0 The ``io_loop`` argument (deprecated since version 4.1) has been removed. .. versionchanged:: 5.1 The ``jitter`` argument is added. .. versionchanged:: 6.2 If the ``callback`` argument is a coroutine, and a callback runs for longer than ``callback_time``, subsequent invocations will be skipped. Previously this was only true for regular functions, not coroutines, which were "fire-and-forget" for `PeriodicCallback`. The ``callback_time`` argument now accepts `datetime.timedelta` objects, in addition to the previous numeric milliseconds. rcallbackCallable[[], Awaitable | None] callback_timedatetime.timedelta | floatjitterfloatreturnNonec||_t|tjr|tjdz |_n|dkrt d||_||_d|_d|_dS)N) millisecondsrz4Periodic callback must have a positive callback_timeF) r! isinstancedatetime timedeltar# ValueErrorr%_running_timeout)selfr!r#r%s r__init__zPeriodicCallback.__init___s %DM-);<< 3%2X5GUV5W5W5W%W"" A%%$N&3" DK!DM DMMMrctj|_d|_|j|_|dS)zStarts the timer.TN)rcurrentio_loopr0time _next_timeout_schedule_nextr2s rstartzPeriodicCallback.startrsH ">++DL DM!%!2!2!4!4D     ! ! ! ! !rcrd|_|j(|j|jd|_dSdS)zStops the timer.FN)r0r1r6remove_timeoutr:s rstopzPeriodicCallback.stop|s<!DM}( ++DM::: $ )(rboolc|jS)znReturns ``True`` if this `.PeriodicCallback` has been started. .. versionadded:: 4.1 )r0r:s r is_runningzPeriodicCallback.is_runnings = rc,K|jsdS |}|t|r|d{Vn,#t$rt jd|jdYnwxYw|dS#|wxYw)NzException in callback %rT)exc_info)r0r!r Exceptionrerrorr9)r2vals r_runzPeriodicCallback._runs=  &mmoo?{3'7'7?IIIIIII X X X 8$-RVWWWWWW X##%%%%%##%%%%s&-;A=&A$!A=#A$$A==Bc|jrX||j|j|j|j|_dSdS)N)r0 _update_nextr6r7 add_timeoutr8rGr1r:s rr9zPeriodicCallback._schedule_nexts]} X!!$,"3"3"5"5666 $ 8 89KTY W W  X Xr current_timec|jdz }|jr$|d|jtjdz zzz}|j|kr5|xjt j||jz |z dz|zz c_dS|xj|z c_dS)Ng@@r*g?)r#r%rr8mathfloor)r2rKcallback_time_secs rrIzPeriodicCallback._update_nexts $ 2V ; { Q!Q$+39N*O%PP!!\11 ""J t/A AEVVWW%'&&""""&""&77""""rN)r)r!r"r#r$r%r&r'r()r'r()r'r?)rKr&r'r() __name__ __module__ __qualname____doc__r3r;r>rArGr9rIrrrr9s# # R  ! ! ! ! !& " " " " % % % % ! ! ! ! & & & & X X X X  8 8 8 8 8 8rr)! __future__rrloggingrsysrtornado__all__r__annotations__update _levelToName _nameToLevelplatformLINUXMACOSWINDOWSrr version_infotornado.iolooprr-rMcollections.abcrrinspectrr tornado.logrrTrrrgs"""""""  I I I,. .... W)*** W)***    ,' !...--- <''////////OOOKKK33333333######%%%%%%######8888888888r