golden hour
/opt/saltstack/salt/lib/python3.10/site-packages/tempora/__pycache__
⬆️ Go Up
Upload
File/Folder
Size
Actions
__init__.cpython-310.pyc
19.71 KB
Del
OK
schedule.cpython-310.pyc
7.36 KB
Del
OK
timing.cpython-310.pyc
7.67 KB
Del
OK
utc.cpython-310.pyc
887 B
Del
OK
Edit: schedule.cpython-310.pyc
o �xe� � @ s� d Z ddlZddlZddlZddlZddlZdd� Zdd� ZG dd� dej�ZG d d � d e�Z G d d � d e �Z G d d� d�Z G dd� de �Z G dd� de �Z dS )a� Classes for calling functions a schedule. Has time zone support. For example, to run a job at 08:00 every morning in 'Asia/Calcutta': >>> job = lambda: print("time is now", datetime.datetime()) >>> time = datetime.time(8, tzinfo=pytz.timezone('Asia/Calcutta')) >>> cmd = PeriodicCommandFixedDelay.daily_at(time, job) >>> sched = InvokeScheduler() >>> sched.add(cmd) >>> while True: # doctest: +SKIP ... sched.run_pending() ... time.sleep(.1) � Nc C s t j �� jtjd�S )u� Provide the current timezone-aware datetime. A client may override this function to change the default behavior, such as to use local time or timezone-naïve times. ��tzinfo)�datetime�utcnow�replace�pytz�utc� r r �D/opt/saltstack/salt/lib/python3.10/site-packages/tempora/schedule.py�now s r c C s t j �| �jtjd�S )u� Convert a numeric timestamp to a timezone-aware datetime. A client may override this function to change the default behavior, such as to use local time or timezone-naïve times. r )r �utcfromtimestampr r r )�tsr r r �from_timestamp" s r c @ sH e Zd ZdZedd� �Zedd� �Zedd� �Zedd � �Z d d � Z d S ) �DelayedCommandzK A command to be executed after some delay (seconds or timedelta). c C s& | |j |j|j|j|j|j|j|j�S �N)�year�month�day�hour�minute�second� microsecondr )�cls�otherr r r � from_datetime1 s �z DelayedCommand.from_datetimec C s< t |tj�s tj|d�}t� | }| �|�}||_||_|S )N��seconds)� isinstancer � timedeltar r �delay�target)r r r Zdue_time�cmdr r r �after> s zDelayedCommand.afterc C s t | tj�s| S t| �S )z� If input is a real number, interpret it as a Unix timestamp (seconds sinc Epoch in UTC) and return a timezone-aware datetime object. Otherwise return input unchanged. )r �numbersZRealr )�inputr r r �_from_timestampH s z DelayedCommand._from_timestampc C s* | � |�}| �|�}|t� |_||_|S )zt Construct a DelayedCommand to come due at `at`, where `at` may be a datetime or timestamp. )r% r r r r )r �atr r! r r r �at_timeS s zDelayedCommand.at_timec C s t � | kS r )r ��selfr r r �due_ � zDelayedCommand.dueN) �__name__� __module__� __qualname__�__doc__� classmethodr r" � staticmethodr% r' r* r r r r r , s r c s< e Zd ZdZdd� Zedd� �Zdd� Z� fdd �Z� Z S ) �PeriodicCommandzY Like a delayed command, but expect this command to run every delay seconds. c C s | � | | j �S )z. Add delay to self, localized )� _localizer r( r r r � _next_timei s zPeriodicCommand._next_timec C s2 z | j }|�| jdd��W S ty | Y S w )zH Rely on pytz.localize to ensure new result honors DST. Nr )r �localizer �AttributeError)�dt�tzr r r r3 o s �zPeriodicCommand._localizec C s$ | j �| �� �}| j|_| j|_|S r )� __class__r r4 r r )r) r! r r r �nextz s zPeriodicCommand.nextc s2 |dkr|t �� kstd��tt| ��||� d S )Nr z7A PeriodicCommand must have a positive, non-zero delay.)r r � ValueError�superr2 � __setattr__)r) �key�value�r9 r r r= � s �zPeriodicCommand.__setattr__) r, r- r. r/ r4 r1 r3 r: r= � __classcell__r r r@ r r2 c s r2 c @ s( e Zd ZdZedd� �Zedd� �ZdS )�PeriodicCommandFixedDelayz� Like a periodic command, but don't calculate the delay based on the current time. Instead use a fixed delay following the initial run. c C s< | � |�}| �|�}t|tj�rtj|d�}||_||_|S )z} >>> cmd = PeriodicCommandFixedDelay.at_time(0, 30, None) >>> cmd.delay.total_seconds() 30.0 r ) r% r r r# �Numberr r r r )r r& r r r! r r r r' � s z!PeriodicCommandFixedDelay.at_timec C sX t jdd�}t j �t j�� |�}||8 }|t� k r"||7 }|t� k s| �| �|�||�S )a Schedule a command to run at a specific time each day. >>> from tempora import utc >>> noon = utc.time(12, 0) >>> cmd = PeriodicCommandFixedDelay.daily_at(noon, None) >>> cmd.delay.total_seconds() 86400.0 � )�days)r r �combine�date�todayr r' r3 )r r& r ZdailyZwhenr r r �daily_at� s �z"PeriodicCommandFixedDelay.daily_atN)r, r- r. r/ r0 r' rI r r r r rB � s rB c @ s6 e Zd ZdZdd� Zdd� Zdd� Zejdd � �Z d S ) � Schedulerzj A rudimentary abstract scheduler accepting DelayedCommands and dispatching them on schedule. c C s g | _ d S r )�queuer( r r r �__init__� r+ zScheduler.__init__c C s t |t�sJ �t�| j|� d S r )r r �bisect�insortrK �r) Zcommandr r r �add� s z Scheduler.addc C sT | j r(| j d }|�� sd S | �|� t|t�r | �|�� � | j d= | j sd S d S )Nr )rK r* �runr r2 rP r: rO r r r � run_pending� s �zScheduler.run_pendingc C s dS )z! Run the command Nr rO r r r rQ � s z Scheduler.runN) r, r- r. r/ rL rP rR �abc�abstractmethodrQ r r r r rJ � s rJ c @ s e Zd ZdZdd� ZdS )�InvokeSchedulerzB Command targets are functions to be invoked on schedule. c C s |� � d S r )r rO r r r rQ � s zInvokeScheduler.runN)r, r- r. r/ rQ r r r r rU � s rU c s( e Zd ZdZ� fdd�Zdd� Z� ZS )�CallbackSchedulerzH Command targets are passed to a dispatch callable on schedule. c s t � �� || _d S r )r< rL �dispatch)r) rW r@ r r rL � s zCallbackScheduler.__init__c C s | � |j� d S r )rW r rO r r r rQ � s zCallbackScheduler.run)r, r- r. r/ rL rQ rA r r r@ r rV � s rV )r/ r r# rS rM r r r r r2 rB rJ rU rV r r r r �<module> s 7%*
Save