o wvXjN2@s$dZddlmZmZmZddlZddlZddlZddlZ ddl m Z ddl m Z m Z mZmZddlmZddlmZddlmZmZdd lmZdd lmZdd lmZmZmZd d lmZd dl m!Z!d dl"m#Z#dZ$ej%&ddZ'dZ(e)e*e(e+dZ,dddddddZ-ddddfddddfd d!d"dfd#d$d%dffZ.edZ/dZ0eGd&d'd'eZ1Gd(d)d)e2Z3e3Zd*d+Z4d,d-Z5dLd.d/Z6d0d1Z7d2d3Z8dMd6d7Z9d8d9Z:d:d;Z;dd?Z=d@dAZ>dNdBdCZ?eGdDdEdEe2Z@e e jAfdFdGZBeBfdHdIZC dOdJdKZDdS)Pz'sr6cC|dSNN@r2r3r2r2r5r6(cCs |ddSr8r2r3r2r2r5r6)s )smhdayg@cC t|dSN.2fformatr3r2r2r5r6- hourg @cCr?r@rBr3r2r2r5r6.rDminuter9cCr?r@rBr3r2r2r5r6/rDsecond?cCr?r@rBr3r2r2r5r60rDc@sPeZdZdZiZddZddZddZdd Zd d Z e r"d d Z ddZ dS)rzpLocal time implementation. Note: Used only when the :setting:`enable_utc` setting is disabled. cCsLttj d|_tjrttj d|_n|j|_|j|j|_t |dS)Nseconds) r_timer STDOFFSETdaylightaltzone DSTOFFSETDSTDIFFr __init__selfr2r2r5rQBs zLocalTimezone.__init__cCsdt|jdS)Nz)rCintrO total_secondsrRr2r2r5__repr__MszLocalTimezone.__repr__cCs||r|jS|jSr1)_isdstrOrLrSdtr2r2r5r%RszLocalTimezone.utcoffsetcCs||r|jStSr1)rXrPZEROrYr2r2r5dstUszLocalTimezone.dstcCstj||Sr1)rKtznamerXrYr2r2r5r]XszLocalTimezone.tznamecCsZt||jd}z|j|}Wnty#t|}|j|<Ynw||j|dS)Nr9r )rUr%rJ _offset_cacheKeyErrorr fromutcreplace)rSrZoffsettzr2r2r5ra]s zLocalTimezone.fromutcc CsD|j|j|j|j|j|j|ddf }t|}t |}|j dkS)Nr) yearmonthr>rErFrGrrKmktime localtimetm_isdst)rSrZttstampr2r2r5rXjs      zLocalTimezone._isdstN) __name__ __module__ __qualname____doc__r_rQrWr%r\r]rrarXr2r2r2r5r8s  rc@s^eZdZdddZdddZerddZnddZd d Zd d Ze d dZ e ddZ dS)_ZoneNcCs|dur|jS||Sr1)local get_timezone)rSr r2r2r5 tz_or_localus z_Zone.tz_or_localcCs(t|r t||p |j}t|||Sr1)rr rr!rs)rSrZrqorigr2r2r5to_local{sz_Zone.to_localcCs |jddS)N)rd) astimezonerYr2r2r5 to_systems z_Zone.to_systemcCs t||jSr1)r!rqrYr2r2r5rws cCs t|r t||jSt||jSr1)rr rqr!rYr2r2r5to_local_fallbacks  z_Zone.to_local_fallbackcCst|tr t|S|Sr1) isinstancer _timezone)rSzoner2r2r5rrs z_Zone.get_timezonecCstSr1)rrRr2r2r5rqsz _Zone.localcCs |dS)NUTC)rrrRr2r2r5rs z _Zone.utcr1)NN) rlrmrnrsrurrwrxrrr rqrr2r2r2r5rpss    rpcCst|tjr t|dS|S)z8Convert integer to timedelta, if argument is an integer.rI)rynumbersRealr)deltar2r2r5rs  rcCst|d}dddfdddfdddff}|j|j|j|j|j|jf}|D]\}}||d kr@t|d |d |j iSq(|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`. rcSr7)NiQr2xr2r2r5r6r:z"delta_resolution..cSr7)NrTr2rr2r2r5r6r:cSr7)N<r2rr2r2r5r6r:rHNr ) maxrVrerfr>rErFrGrr )rZr resolutionsargsres predicater2r2r5rs     rcCs|pt}t|jt|jkr||kr|j|jd}||}|r.t||jdd}||}tr?td|||||f|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) microsecondz2rem: NOW:%r START:%r ENDS_IN:%r END_DATE:%s REM:%s) rutcnowstrr r%rbrr(print)startends_innowrelativeend_dateretr2r2r5rs $ rcCsB|rt|tr|d\}}}t|pdt|pdS|pdSdS)zAConvert rate string (`"100/m"`, `"2/h"` or `"0.5/s"`) to seconds./r;r)ryr partitionRATE_MODIFIER_MAPfloat)rops_modifierr2r2r5rs  rcCs2|dd}zt|WStyt|w)zReturn the position of a weekday: 0 - 7, where 0 is Sunday. Example: >>> weekday('sunday'), weekday('sun'), weekday('mon') (0, 0, 1) rr)lowerWEEKDAYSr`)name abbreviationr2r2r5rs   rrc Cstttt|d}tD]\}}}||kr)|t|}d||||t||Sq |r8|dkr8dj|||dS|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. rAz {0}{1}{2} {3}gz{prefix}{sep}{0:.2f} seconds)sepprefix)rrC TIME_UNITSr) secsrrr microsecondsunitdivider formatterwr2r2r5rs   rcCs|sdSt|tr |St|S)z:Either ``datetime | str -> datetime`` or ``None -> None``.N)ryrrrZr2r2r5rs  rcCs|jdup |j|duS)z=Return :const:`True` if :class:`~datetime.datetime` is naive.N)r r%rr2r2r5rsrc Csfz|j}Wnty|j|dYSwz||ddWSty2t||dd||ddYSw)z6Set timezone for a :class:`~datetime.datetime` object.r^Nis_dstTF)r!AttributeErrorrbr min)rZrd _localizer2r2r5r s     r c Cst|r t||}|jtkr||}z|j}Wn ty#|YSwz||ddWSty8||YStyMt ||dd||ddYSw)z>Convert aware :class:`~datetime.datetime` to another timezone.NrTF) rr r rrv normalizer TypeErrorr r)rZrd _normalizer2r2r5r!,s$          r!cCs t|tjS)z1Convert naive :class:`~datetime.datetime` to UTC.)r rrrr2r2r5r"@s r"cCs4t|rt|}t||durtjSt|S|S)z@Convert dt to aware datetime, do nothing if dt is already aware.N)rr"r!rrrs)rZrdr2r2r5r#Esr#c@s6eZdZdZ  d ddZddZdd Zd d ZdS) r$zBVersion of ``dateutil.relativedelta`` that only supports addition.Nrc KsZ||_||_||_||_||_||_||_||_| |_|d|_ |jdup)|jdu|_ dS)Nr0) rerfweeksrr>rErFrGrdays _has_time) rSrerfrrr>rErFrGrkwargsr2r2r5rQSs z ffwd.__init__cCstdd|j|j|jdS)Nr$r2)rr)r _fieldsrrrRr2r2r5rWdsz ffwd.__repr__c Cst|tstS|jp |j}|jp|j}tt||d|jp|j}|jdit t | |||d}|j durH|t d| |j dd7}|t |jdS)Nr)rerfr>r0)rr2)ryrNotImplementedrerfrrr>rbdictrrrrr)rSotherrerfr>rr2r2r5__radd__hs     z ffwd.__radd__c Ks.t|j|j|j|j|j|j|jdfi|S)N)rerfr>rErFrGr)rrerfr>rErFrGr)rSextrar2r2r5rts z ffwd._fields) NNrNNNNNN)rlrmrnrorQrWrrr2r2r2r5r$Os  r$cCs|jr |jdS|jdS)z*Return the current offset to UTC in hours.rT)rirNr)timerhr2r2r5r%|s  r%cCs|||dS)z-Adjust timestamp based on provided utcoffset.rTr2)tsrcherer2r2r5r&sr&cCs.t||d|}|rt|d}td|S)z,Calculate the exponential backoff wait time.rr)rrandom randranger)factorretriesmaximum full_jitter countdownr2r2r5r's r')NF)rrrFr1)F)Ero __future__rrrr}osrrrKcalendarrrrrr kombu.utils.functionalr kombu.utils.objectsr pytzr r rrzr celery.fiverrr functionalriso8601rtextr__all__environgetr(DAYNAMESrziprangerrrr[_local_timezonerobjectrprrrrrrrrr r!r"r#r$rhr%r&r'r2r2r2r5sl             :,     ,