V.j:$dZddlmZddlZddlZddlZddlZddlZddl m Z ddl m Z m Z m Z ddl mZddl mZddlmZdd lmZmZdd lmZdd lmZdd lmZdd lmZddlm Z ddl!m"Z"ejFdk\rddl$m%Z%nddl&m%Z%dZ'ejPjSddZ*dZ+e,e-e+e.dZ/ddddZ0dddfdd d!fd"d#d$fd%d&d'ffZ1e dZ2dZ3Gd(d)eZ4Gd*d+Z5e5Zd?d,Z6d@d-Z7 dA dBd.Z8dCd/Z9dDd0Z: dE dFd1Z;dGd2ZdJd5Z?dKd6Z@dKd7ZAdLd8ZB dM dNd9ZCGd:d;ZDeejf dOd<ZFeFf dPd=ZG dQ dRd>ZHy)Szr9-s1c |dz SNN@r5r6s r8r9r9.s1t8r:c|dz dz Sr<r5r6s r8r9r9/s 1t8d?r:)smhdayg@ct|dSN.2fformatr6s r8r9r93s fQ&6r:hourg @ct|dSrDrFr6s r8r9r94s &E"2r:minuter=ct|dSrDrFr6s r8r9r95s va/r:second?ct|dSrDrFr6s r8r9r96s fQ.r:cdeZdZUdZiZded<d fd Zd dZd dZd dZ ddZ dd Z dd Z xZ S)raLocal time implementation. Provided in _Zone to the app when `enable_utc` is disabled. Otherwise, _Zone provides a UTC ZoneInfo instance as the timezone implementation for the application. Note: Used only when the :setting:`enable_utc` setting is disabled. zdict[int, tzinfo] _offset_cachec"ttj |_tjr!ttj |_n|j|_|j |jz |_t|%y)Nseconds) r_timer STDOFFSETdaylightaltzone DSTOFFSETDSTDIFFsuper__init__)self __class__s r8r[zLocalTimezone.__init__HsZ#ENN?; >>& ~>DN!^^DN~~6  r:cXdt|jjdz ddS)Nz)intrX total_secondsr\s r8__repr__zLocalTimezone.__repr__Ss-$S)E)E)G$)N%OPT$UUVWWr:cT|j|r |jS|jSr4)_isdstrXrUr\dts r8r'zLocalTimezone.utcoffsetVs!%Rt~~DdnnDr:cH|j|r |jStSr4)rfrYZEROrgs r8dstzLocalTimezone.dstYs#{{2t||8D8r:cFtj|j|Sr4)rTtznamerfrgs r8rmzLocalTimezone.tzname\s||DKKO,,r:ct|j|jdz } |j|}|j|j|S#t$r't t |x}|j|<YPwxYw)Nr=)minutesr ) rar'rSrPKeyErrordatetime_timezonerfromutcreplace)r\rhoffsetrs r8rrzLocalTimezone.fromutc_sT^^B'//$67 +##F+Bzz"**B*/00 +.?&)/+ +B##F+ +sA-B B c |j|j|j|j|j|j |j ddf }tj|}tj|}|jdkDS)Nr) yearmonthrBrHrJrLrrTmktime localtimetm_isdst)r\rhttstamps r8rfzLocalTimezone._isdstjshggrxxggryy"))jjlAq" R  __U #{{Qr:)returnNoner}str)rhrr}r)rhrr}rrhrr}rrhrr}bool)__name__ __module__ __qualname____doc__rP__annotations__r[rdr'rkrmrrrf __classcell__)r]s@r8rr>s:(*M$) XE9- 1r:rc`eZdZdZd d dZd d dZddZddZddZe ddZ e dd Z y)_ZoneagTimezone class that provides the timezone for the application. If `enable_utc` is disabled, LocalTimezone is provided as the timezone provider through local(). Otherwise, this class provides a UTC ZoneInfo instance as the timezone provider for the application. Additionally this class provides a few utility methods for converting datetimes. Nc@| |jS|j|S)z:Return either our local timezone or the provided timezone.)local get_timezone)r\r s r8 tz_or_localz_Zone.tz_or_local{s$ >::   ((r:ct|rt||xs |j}t||j |S)z*Converts a datetime to the local timezone.)r!r"utcr#r)r\rhrorigs r8to_localz_Zone.to_locals8 B<B 01BD,,U344r:c&|jdS)z+Converts a datetime to the system timezone.Nr) astimezonergs r8 to_systemz_Zone.to_systems }}}%%r:cpt|rt||jSt||jS)zBConverts a datetime to the local timezone, or the system timezone.)r!r"rr#rgs r8to_local_fallbackz_Zone.to_local_fallbacks+ B<b$**- -DJJ''r:c<t|tr t|S|S)zVReturns ZoneInfo timezone if the provided zone is a string, otherwise return the zone.) isinstancerr)r\zones r8rz_Zone.get_timezones dC D> ! r:ctS)z2Return LocalTimezone instance for the application.)rrcs r8rz _Zone.locals r:c$|jdS)z*Return UTC timezone created with ZoneInfo.UTC)rrcs r8rz _Zone.utcs  ''r:r4)r tzinfo | Noner}r )NN)rhrr)rz str | tzinfor}r )r}r)r}r ) rrrrrrrrrrrrr5r:r8rrssH)5&(  ((r:rcRt|tjr t|S|S)z8Convert integer to timedelta, if argument is an integer.rR)rnumbersRealr)deltas r8rrs %&'' Lr:c<t|jd}ddfddfddff}|j|j|j|j |j |jf}|D]*\}}||dk\st|d |d |jicS|S) aRound a :class:`~datetime.datetime` to the resolution of timedelta. If the :class:`~datetime.timedelta` is in days, the :class:`~datetime.datetime` will be rounded to the nearest days, if the :class:`~datetime.timedelta` is in hours the :class:`~datetime.datetime` will be rounded to the nearest hour, and so on until seconds, which will just return the original :class:`~datetime.datetime`. rrc |dz S)NiQr5xs r8r9z"delta_resolution..sUr:c |dz S)Nr_r5rs r8r9z"delta_resolution..sTr:c |dz S)N<r5rs r8r9z"delta_resolution..sRr:rMNr ) maxrbrvrwrBrHrJrLrr )rhr resolutionsargsres predicates r8rrs ##%q )E*+)*'(*K 77BHHbffbggryy")) CD%Y U s "T$3Z: : :& Ir:c |xs#tjtj}t |j t |j k(r=|j |j k7r|j|j }||z}|rt||jd}||z }trtdj||||||S)ajCalculate the remaining time for a start date and a timedelta. For example, "how many seconds left for 30 seconds after start?" Arguments: start (~datetime.datetime): Starting date. ends_in (~datetime.timedelta): The end delta. relative (bool): If enabled the end time will be calculated using :func:`delta_resolution` (i.e., rounded to the resolution of `ends_in`). now (Callable): Function returning the current time and date. Defaults to :func:`datetime.now(timezone.utc)`. Returns: ~datetime.timedelta: Remaining time. r r) microsecondz8rem: NOW:{!r} START:{!r} ENDS_IN:{!r} END_DATE:{} REM:{}) rnowrqrrr r'rsrr*printrG)startends_inrrelativeend_daterets r8rrs&  4/334C LL JJMMOu/@@ SZZ 0wH#Hg6>>1>M S.C HOO 30 1 Jr:c|rJt|tr4|jd\}}}t|xsdt |xsdS|xsdSy)zAConvert rate string (`"100/m"`, `"2/h"` or `"0.5/s"`) to seconds./r?r)rr partitionRATE_MODIFIER_MAPfloat)rops_modifiers r8rrsM a  {{3/ CH$X_5eCjAFQ FvA r:cl|ddj} t|S#t$r t|wxYw)zReturn the position of a weekday: 0 - 7, where 0 is Sunday. Example: >>> weekday('sunday'), weekday('sun'), weekday('mon') (0, 0, 1) rr)lowerWEEKDAYSrp)name abbreviations r8rrs?!9??$L %% tns3c ttt|d}tD]?\}}}||k\s |t|z }dj||||t||cS|r|dkDrdj|||S|S)a[Show seconds in human form. For example, 60 becomes "1 minute", and 7200 becomes "2 hours". Arguments: prefix (str): can be used to add a preposition to the output (e.g., 'in' will give 'in 1 second', but add nothing to 'now'). now (str): Literal 'now'. microseconds (bool): Include microseconds. rEz {}{}{} {}gz{prefix}{sep}{0:.2f} seconds)sepprefix)rrG TIME_UNITSr) secsrrr microsecondsunitdivider formatterws r8rrs d U+ ,D$. gy 7?uW~%A%%fc9Q<&/4&8: :%/ s -44 c&5* * Jr:cB|syt|tr|St|S)z:Either ``datetime | str -> datetime`` or ``None -> None``.N)rrrrhs r8r r s! "h B<r:c\|jduxs|jj|duS)z_Return True if :class:`~datetime.datetime` is naive, meaning it doesn't have timezone info set.N)r r'rs r8r!r!'s* 99  ? 3 3B 74 ??r:c>t|txs t|dS)zUHelper function to determine if a timezone can detect ambiguous times using dateutil. is_ambiguous)rrhasattrrs r8_can_detect_ambiguousr,s b( # Bwr>'BBr:cFt|xrtj|S)aHelper function to determine if a timezone is ambiguous using python's dateutil module. Returns False if the timezone cannot detect ambiguity, or if there is no ambiguity, otherwise True. In order to detect ambiguous datetimes, the timezone must be built using ZoneInfo, or have an is_ambiguous method. Previously, pytz timezones would throw an AmbiguousTimeError if the localized dt was ambiguous, but now we need to specifically check for ambiguity with dateutil, as pytz is deprecated. )r dateutil_tzdatetime_ambiguousrhrs r8 _is_ambigiousr2s ! $ K)G)G)KKr:c|j|}t||r,t|jd|jd}|S)z6Set timezone for a :class:`~datetime.datetime` object.r r)foldr)rsrminrs r8r"r"?sE 2 BR #RZZQZ%7 8 Ir:ct|r t||}|jtdk(r|j |}|S)zConvert aware :class:`~datetime.datetime` to another timezone. Using a ZoneInfo timezone will give the most flexibility in terms of ambiguous DST handling. r)r!r"r rrrs r8r#r#Hs: | B  yyHUO# ]]2  Ir:c6t|tjS)z1Convert naive :class:`~datetime.datetime` to UTC.)r"rrrs r8r$r$Ts b(,, ''r:ct|rB|r t|}t||tjStj |S|S)z@Convert dt to aware datetime, do nothing if dt is already aware.)r!r$r#rrr)rhr naive_as_utcs r8r%r%YsP| B     080D0DR0H   Ir:c8eZdZdZ d ddZd dZd dZd dZy) r&zBVersion of ``dateutil.relativedelta`` that only supports addition.Nc  ||_||_||_||_||_||_||_||_| |_|dz|_ |j duxs|j du|_ y)Nr2) rvrwweeksrrBrHrJrLrdays _has_time) r\rvrwrrrBrHrJrLrkwargss r8r[z ffwd.__init__hsm        &AI $.I$++T2Ir:cftdd|j|j|jS)Nr&r5)rr)r_fieldsrrrcs r8rdz ffwd.__repr__ys3DLLtzz9=%1%GH Hr:c t|tstS|jxs |j}|jxs |j}t t ||d|jxs |j}|jditt|j|||}|j0|td|jz |jzdzz }|t|jzS)Nr)rvrwrBr2)rr5)rrNotImplementedrvrwrrrBrsdictrrrrr)r\otherrvrwrBrs r8__radd__z ffwd.__radd__}s%&! !yy&EJJ )ekk*T5)!,dhh.C%))DemmEd:dlln#=(,EsDE << # 91s{{}#4t||#Cq"HI ICYDII...r:c t|j|j|j|j|j |j |jdfi|S)N)rvrwrBrHrJrLr)rrvrwrBrHrJrLr)r\extras r8rz ffwd._fieldssMII 488IIkk$2B2B   r:) NNrNNNNNN)rr r)rr r}r)rr r}zdict[str, Any])rrrrr[rdrrr5r:r8r&r&es*LIMBFJJ"H /r:r&c`|jr|jdzS|jdzS)z*Return the current offset to UTC in hours.r_)rzrWr)timerys r8r'r's-{||t## ==D  r:c"|||z dzz S)z-Adjust timestamp based on provided utcoffset.r_r5)tsrtheres r8r(r(s $&D( ((r:crt||d|zz}|rtj|dz}td|S)z,Calculate the exponential backoff wait time.rr)rrandom randranger)factorretriesmaximum full_jitter countdowns r8r)r)s?GVqG|45I$$Y]3 q) r:)rrar}r)rhrrrr}r)NF) rrrrrzCallable | Nonerrr}r)rrr}r)rrr}ra)rrF) rrarrrrrrrrr}r)rhzdatetime | str | Noner}zNone | datetimer)rr r}r)rhrrr r}r)rhrrr r}rr)NT)rhrrrrrr}r)rr ryz Callable[..., _time.struct_time]r}r)rrrtrarzCallable[..., float]r}r)F) rrarrarrarrr}ra)Ir __future__rrosrsysrrTcalendarrrrrrrqr typesr typingr r dateutilrrdateutil.parserrkombu.utils.functionalrkombu.utils.objectsr functionalrtextr version_infozoneinforbackports.zoneinfo__all__environgetr*DAYNAMESrziprangerrrrj_local_timezonerrrrrrrrr r!rrr"r#r$r%r&ryr'r(r)r5r:r8rsYB" ..2 &$+/"v!+ ZZ^^L% 0 : HeAh' (   " N67 Y23 t/0 s./  |2F2j2(2(j 70EI  "+ 2A  #, F   @E"*-9<'*2@ C L ( 8<*. #' 3; ))Z!6;oo!!3!JO!3<)/)@E)      r: