a

X>h�=�@
s dZd
dl
mZ
d
dlZd
dlZd
dlZd
dlZd
dlZd
dl	m
Z

d
dlmZmZm
Z

d
dlmZ
d
dlmZ
d
dlmZ
d
d	lmZmZ
d
d
lmZ
d
dlmZ
d
dlmZ
d
d
lmZ
ddlm Z 
ddl!m"Z"
ej#dkr�d
dl$m%Z%
nd
dl&m%Z%
dZ'ej(�)dd�Z*dZ+e,e-e+e.d�
��
Z/dZ0e,e-e0e.dd���
Z1dd�dd�dd�d�Z2dd d!d�fd"d#d$d�fd%d&d'd�fd(d)d*d�ffZ3e
d
�
Z4dZ5Gd+d,�d,e�Z6Gd-d.�d.�Z7e7�Zd/d0d1�d2d3�Z8d4d0d4d5�d6d7�Z9dsd4d0d8d9d0d:�d;d<�Z:d=d>d?�d@dA�Z;d=d/dB�dCdD�Z<d=d/dB�dEdF�Z=dtd/d=d=d=d9d=dI�dJdK�Z>dLdMdN�dOdP�Z?d4d9dN�dQdR�Z@dSd9dT�dUdV�ZAd4dSd9dW�dXdY�ZBd4dSd4dW�dZd[�ZCd4dSd4dW�d\d]�ZDd4d4dN�d^d_�ZEdud4dad9d4db�dcdd�ZFGdedf�df�ZGeejHfdgdhd>di�djdk�ZIeIf
d>d/dld>dm�dndo�ZJdvd/d/d/d9d/dp�dqdr�ZKdS)wz<Utilities related to dates, times, intervals, and timezones.�)
�annotationsN)
�
monthrange)�date�datetime�	timedelta)
�timezone�
�tzinfo)
�
ModuleType)�Any�Callable�
�tz)
�isoparse)
�reprcall)
�cached_property�
)
�
dictfilter)
�	pluralize)��	)
�ZoneInfo)�
LocalTimezoner�maybe_timedelta�delta_resolution�	remaining�rate�weekday�humanize_seconds�
maybe_iso8601�is_naive�
make_aware�localize�to_utc�maybe_make_aware�ffwd�	utcoffset�adjust_timestamp� get_exponential_backoff_interval�
C_REMDEBUGF)�sun�mon�tue�wed�thu�fri�sat�)�jan�feb�mar�apr�may�jun�jul�aug�sep�oct�nov�dec�
c


C
s|S�
N��
�
nr@r@�;/usr/local/lib/python3.9/site-packages/celery/utils/time.py�<lambda>0�rDc

C
s|d
S�N�N@r@rAr@r@rCrD1rEc

C
s|d
d
SrFr@rAr@r@rCrD2rE)�
s�
m�
h�dayg�@c

C
s
t|d
�S�N�.2f�
�formatrAr@r@rCrD6rE�hourg �@c

C
s
t|d
�SrLrNrAr@r@rCrD7rE�minuterGc

C
s
t|d
�SrLrNrAr@r@rCrD8rE�second��?c

C
s
t|d
�SrLrNrAr@r@rCrD9rEc
s�eZ
dZUd
ZiZded<dd�
�f
dd�Zdd�
d	d
�Zddd
�dd�Zddd
�dd�Z	ddd
�dd�Z
ddd
�dd�Zddd
�dd�Z�Z
S)ra
Local 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_cache�None�
�returnc


sLtt
jd
�
|_t
jr(tt
jd
�
|_n|j|_|j|j|_t��	�
dS)N�
�seconds)
r�_timer�	STDOFFSET�daylight�altzone�	DSTOFFSET�DSTDIFF�super�__init__�
�self�
�	__class__r@rCraKs



zLocalTimezone.__init__�strc

C
sd
t|j
��d�
d�d�S)Nz<LocalTimezone: UTC�z+03d�
>)�intr^�
total_secondsrbr@r@rC�__repr__Vs
zLocalTimezone.__repr__rr��dtrWcC
s|�|
�
r|j
S|jSr?)�_isdstr^r[�rcrmr@r@rCr&Ys
zLocalTimezone.utcoffsetcC
s|�|
�
r|j
StSr?)rnr_�ZEROror@r@rC�dst\s
zLocalTimezone.dstcC
stj
|�|
�
Sr?)rZ�tznamernror@r@rCrr_s
zLocalTimezone.tznamecC
s`t|�
|
�
jd
�
}z|j|}Wn*tyL


tt|d�
�
}|j|<Yn0|�|
j|d�
�
S)NrG)
�minutesr)	rir&rYrT�KeyError�datetime_timezoner�fromutc�replace)rcrm�offsetrr@r@rCrvbs




�zLocalTimezone.fromutc�boolc	C
sD|
j|
j
|
j|
j|
j|
j|
��d
d
f	}t�|�
}t�	|�
}|j
d
kS)Nr
)�year�monthrKrPrQrRrrZ�mktime�	localtime�tm_isdst)rcrm�ttZstampr@r@rCrnms



�



zLocalTimezone._isdst)�__name__�
__module__�__qualname__�__doc__rT�__annotations__rarkr&rqrrrvrn�
__classcell__r@r@rdrCrAs

rc@
s�eZ
dZd
Zdddd�dd�Zddd	�
d
d�Zddd�d
d�Zddd�dd�Zddd�dd�Ze	dd�
dd��
Z
e	dd�
dd��
ZdS)�_Zoneag
Timezone 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.
    N�
tzinfo | Noner	)r	rWcC
s|
d
ur|jS|�
|
�
S)z:Return either our local timezone or the provided timezone.N)�local�get_timezone)rcr	r@r@rC�tz_or_local~s

z_Zone.tz_or_localr�
rmcC
s(t|
�
rt
|
|p|j�}
t|
|�|�
�S)
z*Converts a datetime to the local timezone.)r r!�utcr"r�)rcrmr��origr@r@rC�to_local�s

z_Zone.to_localrlcC
s|
jd
d�
S)z+Converts a datetime to the system timezone.Nr
)
�
astimezoneror@r@rC�	to_system�sz_Zone.to_systemcC
s t|
�
rt
|
|j�St|
|j�S)
zBConverts a datetime to the local timezone, or the system timezone.)r r!r�r"ror@r@rC�to_local_fallback�s

z_Zone.to_local_fallbackzstr | tzinfo)�zonerWcC
st|
t
�rt|
�
S|
S)
zVReturns ZoneInfo timezone if the provided zone is a string, otherwise return the zone.)�
isinstancerfr)rcr�r@r@rCr��s


z_Zone.get_timezonerrVc


C
st�S)
z2Return LocalTimezone instance for the application.)
rrbr@r@rCr��sz_Zone.localc

C
s
|�d
�
S)z*Return UTC timezone created with ZoneInfo.�UTC)
r�rbr@r@rCr��sz	_Zone.utc)
N)NN)r�r�r�r�r�r�r�r�r�rr�r�r@r@r@rCr�vs


r�rir)�deltarWc

C
st|t
j�rt|d
�
S|S)z8Convert integer to timedelta, if argument is an integer.rX)r��numbers�Realr)
r�r@r@rCr�s


rr)rmr�rWcC
s�t|
�
�d
�}
ddd�fddd�fddd�ff}|j|j|j|j|j|jf}|D]0\}}||
�
d	krPt|d
|�d|j	i
�

SqP|S)a�
Round 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`.
    r
rc

S
s|d
S)Ni�Q
r@�
�
xr@r@rCrD�rEz"delta_resolution.<locals>.<lambda>�c

S
s|d
S)Nrgr@r�r@r@rCrD�rE�c

S
s|d
S)N�<r@r�r@r@rCrD�rErSNr	)
�maxrjrzr{rKrPrQrRrr	)rmr��resolutions�args�res�	predicater@r@rCr�s





�



rzCallable | Nonery)�start�ends_in�now�relativerWc
C
sp|pt�
tj�
}||
}|r.t||
�jd
d�
}|�tj�
}|�tj�
}||}trlt	d�
||||
|||��

|S)aoCalculate the real 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
)
�microsecondzWrem: NOW:{!r} NOW_UTC:{!r} START:{!r} ENDS_IN:{!r} END_DATE:{} END_DATE_UTC:{!r} REM:{})rr�rur�rrwr�rr)�printrO)r�r�r�r��end_dateZnow_utcZend_date_utc�retr@r@rCr�s







��rrf�float)�
rrWc
C
sB|r>t|t
�r6|�d
�
\}
}}t|p&dt|
�
�
p4dS|p<dSdS)zAConvert rate string (`"100/m"`, `"2/h"` or `"0.5/s"`) to seconds.�
/rHr
)r�rf�	partition�RATE_MODIFIER_MAPr�)r��ops�
_�modifierr@r@rCr�s





r)�namerWc
C
s:|d
d���}
z
t
|
WSty4


t|�
�
Yn0dS)z�Return the position of a weekday: 0 - 7, where 0 is Sunday.

    Example:
        >>> weekday('sunday'), weekday('sun'), weekday('mon')
        (0, 0, 1)
    r
rN)�lower�WEEKDAYSrt�r�Zabbreviationr@r@rCr�s




rc
C
s:|d
d���}
z
t
|
WSty4


t|�
�
Yn0dS)z�Return the position of a month: 1 - 12, where 1 is January.

    Example:
        >>> yearmonth('january'), yearmonth('jan'), yearmonth('may')
        (1, 1, 5)
    r
rN)r��
YEARMONTHSrtr�r@r@rC�	yearmonth
s




r��r�)�secs�prefixr:r��microsecondsrWc		C
sttt
t|�
d
��
}tD]<\}}}||kr|t|�
}d�
|
|||�
t||��
Sq|rp|dkrpdj
|||
d�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.
    rMz	{}{}{} {}gz{prefix}{sep}{0:.2f} seconds)r:r�)r�rO�
TIME_UNITSr)	r�r�r:r�r��unit�divider�	formatter�
wr@r@rCr
s





�


�rzdatetime | str | NonezNone | datetimerlc

C
s|sd
St|t
�r|St|�
S)z:Either ``datetime | str -> datetime`` or ``None -> None``.N)r�rrr�r@r@rCr4
s





rc

C
s|jd
up|j�
|�
d
uS)z_Return True if :class:`~datetime.datetime` is naive, meaning it doesn't have timezone info set.N)r	r&r�r@r@rCr =
sr r	)rrWc

C
st|t
�pt|d
�S)zUHelper function to determine if a timezone can detect ambiguous times using dateutil.Zis_ambiguous)r�r�hasattrr
r@r@rC�_can_detect_ambiguousB
sr�)rmrrWcC
st|
�
ot
�|�
S)
a�
Helper 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_tzZdatetime_ambiguous�rmrr@r@rC�
_is_ambiguousH
s
r�cC
s4|j|
d
�
}t
||
�r0t|jdd�
|jdd�
�}|S)z6Set timezone for a :class:`~datetime.datetime` object.rr
)
�foldr)rwr��minr�r@r@rCr!U
s



r!cC
s.t|�
rt
||
�}|jtd
�
kr*|�|
�
}|S)z�Convert 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	rr�r�r@r@rCr"^
s






r"c

C
st|t
j�S)
z1Convert naive :class:`~datetime.datetime` to UTC.)r!rr�r�r@r@rCr#j
sr#Tr�)rmr�naive_as_utcrWcC
s6t|�
r2|rt
|�
}t||
d
ur&tjnt�|
�
�S|S)z@Convert dt to aware datetime, do nothing if dt is already aware.N)r r#r"rr�r�)rmrr�r@r@rCr$o
s



�r$c	@
sNeZ
dZd
Zddd�
dd�Zdd	�
d
d�Zddd
�dd�Zddd�dd�ZdS)r%zBVersion of ``dateutil.relativedelta`` that only supports addition.Nr
r)
�kwargsc
K
sZ|
|_||_
||_||_||_||_||_||_|	|_|d
|_	|jdu
pR|jdu
|_
dS)Nr1)rzr{�weeksrrKrPrQrRr��daysZ	_has_time)rcrzr{r�rrKrPrQrRr�r�r@r@rCra~
s










z
ffwd.__init__rfrVc

C
std
d|j
|j|jd��S)Nr%r@)r�r)r�_fieldsr�rrbr@r@rCrk�
s

�z
ffwd.__repr__r)�otherrWc	C
s�t|
t
�stS|jp|
j}|jp$|
j}tt||�d
|jp>|
j�}|
jfit	t
|���
|||d��
�
}|jdu
r�|t
d|��|jdd�
7}|t
|jd�
S)Nr)rzr{rKr1)
r�)r�r�NotImplementedrzr{r�rrKrw�dictrr�rrr�)rcr�rzr{rKr�r@r@rC�__radd__�
s







�


 
z
ffwd.__radd__zdict[str, Any])�extrarWc
	K
s.t|j
|j|j|j|j|j|jd
�f
i|
�
�
S)N)rzr{rKrPrQrRr�)rrzr{rKrPrQrRr�)rcr�r@r@rCr��
s



��zffwd._fields)	NNr
NNNNNN)r�r�r�r�rarkr�r�r@r@r@rCr%{
s

�r%r
z Callable[..., _time.struct_time])�timer}rWcC
s|
�jr|j
d
S|jd
S)z*Return the current offset to UTC in hours.rg)r~r]r)r�r}r@r@rCr&�
s


r&zCallable[..., float])�tsrx�hererWcC
s||
|�d
S)z-Adjust timestamp based on provided utcoffset.rgr@)r�rxr�r@r@rCr'�
sr')�factor�retries�maximum�full_jitterrWcC
s.t||d
|
�}|r$t
�|d�
}td|�S)z,Calculate the exponential backoff wait time.�rr
)r��random�	randranger�)r�r�r�r�Z	countdownr@r@rCr(�
s
r()NF)r�r�r�F)NT)
F)Lr��
__future__rr��osr��sysr�rZ�calendarrrrrrrur	�typesr
�typingrrZdateutilrr�Zdateutil.parserrZkombu.utils.functionalrZkombu.utils.objectsrZ
functionalr�textr�version_infoZzoneinforZbackports.zoneinfo�__all__�environ�getr)ZDAYNAMESr��zip�ranger�Z
MONTHNAMESr�r�r�rpZ_local_timezonerr�rrrrrr�rrr r�r�r!r"r#r$r%r}r&r'r(r@r@r@rC�<module>
s�
















	



�


�55
�'

�	
	
�-
�
�
�