`f:dZddlmZddlZddlZddlZddlZddlZddl m Z ddl m Z m Z m Z ddl mZddl mZddlmZdd lmZmZdd lmZdd lmZdd lmZdd lmZddlm Z ddl!m"Z"ej#dkrddl$m%Z%nddl&m%Z%dZ'ej()ddZ*dZ+e,e-e+e.dZ/ddddZ0dddfdd d!fd"d#d$fd%d&d'ffZ1e dZ2dZ3Gd(d)eZ4Gd*d+Z5e5Zdgd0Z6dhd3Z7 didjd:Z8dkd>Z9dld@Z: dmdndFZ;dodIZdrdNZ?dsdOZ@dsdPZAdtdQZB dudvdUZCGdVdWZDeejEfdwd\ZFeFfdxdaZG dydzdfZHdS){zr9-s1c |dz SNN@r5r6s r8r9r9.s 1t8r:c|dz dz Sr<r5r6s r8r9r9/s1t8d?r:)smhdayg@c"t|dSN.2fformatr6s r8r9r93sfQ&6&6r:hourg @c"t|dSrDrFr6s r8r9r94s&E"2"2r:minuter=c"t|dSrDrFr6s r8r9r95sva//r:second?c"t|dSrDrFr6s r8r9r96sfQ..r:cdeZdZUdZiZded<dfd ZddZdd Zdd Z ddZ ddZ ddZ 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_cachereturnNonec"ttj |_tjr!ttj |_n |j|_|j|jz |_t dS)Nseconds) r_timer STDOFFSETdaylightaltzone DSTOFFSETDSTDIFFsuper__init__)self __class__s r8r]zLocalTimezone.__init__Hsr#EN?;;; > ,& ~>>>DNN!^DN~6  r:strc^dt|jdz ddS)Nz)intrZ total_secondsr^s r8__repr__zLocalTimezone.__repr__Ss1WS)E)E)G)G$)N%O%OWWWWWr:dtrrcH||r|jn|jSr4)_isdstrZrWr^rhs r8r'zLocalTimezone.utcoffsetVs!%RDt~~dnDr:cH||r|jntSr4)rjr[ZEROrks r8dstzLocalTimezone.dstYs#{{28t||D8r:cLtj||Sr4)rVtznamerjrks r8rpzLocalTimezone.tzname\s|DKKOO,,r:c4t||jdz } |j|}n7#t$r*t t |x}|j|<YnwxYw|||S)Nr=)minutesr ) rdr'rUrPKeyErrordatetime_timezonerfromutcreplace)r^rhoffsetrs r8ruzLocalTimezone.fromutc_sT^^B''/$677 +#F+BB + + +.?&)))/+/+ +B#F+++ +zz"**B*//000s :1A.-A.boolc |j|j|j|j|j|j|ddf }tj|}tj |}|j dkS)Nr) yearmonthrBrHrJrLrrVmktime localtimetm_isdst)r^rhttstamps r8rjzLocalTimezone._isdstjs^grxgry")jjllAq" R   _U # #{Qr:)rQrRrQr`)rhrrQr)rhrrQr`rhrrQrrhrrQrx)__name__ __module__ __qualname____doc__rP__annotations__r]rgr'rnrprurj __classcell__)r_s@r8rr>s(*M))))      XXXXEEEE9999---- 1 1 1 1r:rcneZdZdZdddZddd Zdd Zdd ZddZe ddZ e ddZ dS)_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. Nr tzinfo | NonerQc>||jS||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:rhrct|rt||p|j}t|||S)z*Converts a datetime to the local timezone.)r!r"utcr#r)r^rhrorigs r8to_localz_Zone.to_localsF B<< 2B 011BD,,U33444r:c.|dS)z+Converts a datetime to the system timezone.Nr) astimezonerks r8 to_systemz_Zone.to_systems }}}%%%r:ctt|rt||jSt||jS)zBConverts a datetime to the local timezone, or the system timezone.)r!r"rr#rks r8to_local_fallbackz_Zone.to_local_fallbacks4 B<< .b$*-- -DJ'''r:zone str | tzinfocNt|trt|S|S)zVReturns ZoneInfo timezone if the provided zone is a string, otherwise return the zone.) isinstancer`r)r^rs r8rz_Zone.get_timezones% dC  "D>> ! r:rctS)z2Return LocalTimezone instance for the application.)rrfs r8rz _Zone.localsr:c,|dS)z*Return UTC timezone created with ZoneInfo.UTC)rrfs r8rz _Zone.utcs  '''r:r4)r rrQr )NN)rhrr)rrrQr )rQr)rQr ) rrrrrrrrrrrrr5r:r8rrss)))))55555&&&&((((  _(((_(((r:rdeltardrQrcZt|tjrt|S|S)z8Convert integer to timedelta, if argument is an integer.rT)rnumbersRealr)rs r8rrs,%&&('''' Lr:rhrct|d}ddfddfddff}|j|j|j|j|j|jf}|D]/\}}||dkrt|d |d |j icS0|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..s Ur:c |dz S)Nrbr5rs r8r9z"delta_resolution..s Tr:c |dz S)N<r5rs r8r9z"delta_resolution..s Rr:rMNr ) maxrerzr{rBrHrJrLrr )rhr resolutionsargsres predicates r8rrs ##%%q ) )E**+))*''(*K 7BHbfbgry") CD%;;Y 9U  s " "T$3$Z: :: : : : # Ir:startends_innowCallable | Nonerelativerxc |ptj}t|jt|jkrE||kr||j}||z}|r$t ||d}||z }tr&td ||||||S)a_Calculate 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.utcnow`. Returns: ~datetime.timedelta: Remaining time. r r) microsecondz8rem: NOW:{!r} START:{!r} ENDS_IN:{!r} END_DATE:{} REM:{}) rutcnowr`r r'rvrr*printrG)rrrrend_daterets r8rrs&  """C L JMMOOu/@/@@@ SZ 00wHN#Hg66>>1>MM S.C1 HOO 300 1 1 1 Jr:rr`floatc|rXt|tr?|d\}}}t|pdt |pdS|pdSdS)zAConvert rate string (`"100/m"`, `"2/h"` or `"0.5/s"`) to seconds./r?r)rr` partitionRATE_MODIFIER_MAPr)rops_modifiers r8rrse a   G {{3// CH$X_5eCjjAAFQ FvA 1r:namec|dd} t|S#t$rt|wxYw)zReturn the position of a weekday: 0 - 7, where 0 is Sunday. Example: >>> weekday('sunday'), weekday('sun'), weekday('mon') (0, 0, 1) rr)lowerWEEKDAYSrs)r abbreviations r8rrsR!9??$$L %% tnns +Asecsprefixsep microsecondsc Httt|d}tD]O\}}}||krC|t|z }d||||t||cSP|r|dkrd|||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)rr)rrG TIME_UNITSr) rrrrrunitdivider formatterws r8rrs d U++ , ,D$.:: gy 7??uW~~%A%%fc99Q<<&/4&8&8:: : : : *s -44 c&5** * Jr:datetime | str | NoneNone | datetimecV|sdSt|tr|St|S)z:Either ``datetime | str -> datetime`` or ``None -> None``.N)rrrrhs r8r r s2 "h B<<r:cL|jdup|j|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) 9  ? 3 3B 7 74 ??r:rr cLt|tpt|dS)zUHelper function to determine if a timezone can detect ambiguous times using dateutil. is_ambiguous)rrhasattrrs r8_can_detect_ambiguousr,s# b( # # Bwr>'B'BBr:cHt|otj|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)K)KKr:c||}t||r8t|d|d}|S)z6Set timezone for a :class:`~datetime.datetime` object.r r)foldr)rvrminrs r8r"r"?sY 2  BR9 ##RZZQZ%7%7 8 8 Ir:ct|rt||}|jtdkr||}|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#HsJ || B   yHUOO## ]]2   Ir:c6t|tjS)z1Convert naive :class:`~datetime.datetime` to UTC.)r"rrrs r8r$r$Ts b(, ' ''r:Tr naive_as_utcct|rG|rt|}t|| tjnt|S|S)z@Convert dt to aware datetime, do nothing if dt is already aware.)r!r$r#rrr)rhrrs r8r%r%Ys[||  B   0D0DR0H0H    Ir:c8eZdZdZ dddZdd Zdd ZddZdS)r&zBVersion of ``dateutil.relativedelta`` that only supports addition.Nrkwargsr c  ||_||_||_||_||_||_||_||_| |_|dz|_ |jdup|jdu|_ dS)Nr2) rzr{weeksrrBrHrJrLrdays _has_time) r^rzr{rrrBrHrJrLrrs r8r]z ffwd.__init__hsm        &AI $.I$+T2Ir:rQr`cbtdd||j|jS)Nr&r5)rr)r_fieldsrrrfs r8rgz ffwd.__repr__ys;DLLtz9=%1%G%GHH Hr:otherrc t|tstS|jp|j}|jp|j}t t ||d|jp|j}|jditt| |||}|j 3|td| z |j zdzz }|t|jzS)Nr)rzr{rBr2)rr5)rrNotImplementedrzr{rrrBrvdictrrrrr)r^rrzr{rBrs r8__radd__z ffwd.__radd__}s%&& "! !y&EJ )ek*T5))!,dh.C%)DDemEEd:dllnn#=#=(,EsDDDEE < # 91s{{}}#4t|#Cq"HIII ICYDI.....r:extradict[str, Any]c rt|j|j|j|j|j|j|jdfi|S)N)rzr{rBrHrJrLr)rrzr{rBrHrJrLr)r^rs r8rz ffwd._fieldssMI 48Ik$2B    r:) NNrNNNNNN)rr r)rr rQr)rr rQr)rrrrr]rgrrr5r:r8r&r&es~LLIMBFJJJJJ"HHHH / / / /r:r&timer r} Callable[..., _time.struct_time]cH|jr |jdzS|jdzS)z*Return the current offset to UTC in hours.rb)r~rYr)rr}s r8r'r's/y{{$|t## =D  r:tsrwhereCallable[..., float]c(|||z dzz S)z-Adjust timestamp based on provided utcoffset.rbr5)rrwrs r8r(r(s $$&&D( ((r:factorretriesmaximum full_jitterct||d|zz}|rtj|dz}td|S)z,Calculate the exponential backoff wait time.rr)rrandom randranger)rrrr countdowns r8r)r)sJGVqG|455I4$Y]33 q)  r:)rrdrQr)rhrrrrQr)NF) rrrrrrrrxrQr)rr`rQr)rr`rQrd)rrrF) rrdrr`rr`rr`rrxrQr`)rhrrQrr)rr rQrx)rhrrr rQrx)rhrrr rQrr)NT)rhrrrrrxrQr)rr r}rrQr)rrrwrdrrrQr)F) rrdrrdrrdrrxrQrd)Ir __future__rrosr sysrrVcalendarrrrrrrtr typesr typingr r dateutilrrdateutil.parserrkombu.utils.functionalrkombu.utils.objectsr functionalrtextr version_infozoneinforbackports.zoneinfo__all__environgetr*DAYNAMESrziprangerrrrm_local_timezonerrrrrrrrr r!rrr"r#r$r%r&r}r'r(r)r5r:r8r"sjBB"""""" ..........222222 &&&&&&$$$$$$++++++//////""""""v!!!!!!!++++++ Z^^L% 0 0 : 4HeeAhh'' ( (    " " N667 Y223 t//0 s../  y||22222F222j2(2(2(2(2(2(2(2(j 5770EI     F         @E"2@@@@ CCCC L L L L    (((( 8<*.     ))))))))Z!6;o!!!!!3<))))) r: