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: timing.cpython-310.pyc
o �xe6 � @ s| d dl Z d dlZd dlZd dlZd dlZd dlZd dlZG dd� d�Z G dd� d�Z G dd� de �Z G dd � d ej j �ZdS ) � Nc @ sH e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dS )� Stopwatcha� A simple stopwatch which starts automatically. >>> w = Stopwatch() >>> _1_sec = datetime.timedelta(seconds=1) >>> w.split() < _1_sec True >>> import time >>> time.sleep(1.0) >>> w.split() >= _1_sec True >>> w.stop() >= _1_sec True >>> w.reset() >>> w.start() >>> w.split() < _1_sec True It should be possible to launch the Stopwatch in a context: >>> with Stopwatch() as watch: ... assert isinstance(watch.split(), datetime.timedelta) In that case, the watch is stopped when the context is exited, so to read the elapsed time:: >>> watch.elapsed datetime.timedelta(...) >>> watch.elapsed.seconds 0 c C s | � � | �� d S �N)�reset�start��self� r �B/opt/saltstack/salt/lib/python3.10/site-packages/tempora/timing.py�__init__, s zStopwatch.__init__c C s@ t �d�| _t�t�� | `W d � d S 1 sw Y d S �Nr )�datetime� timedelta�elapsed� contextlib�suppress�AttributeError� start_timer r r r r 0 s "�zStopwatch.resetc C s t j �� | _d S r )r �utcnowr r r r r r 5 � zStopwatch.startc C s( t j �� }| j|| j 7 _| `| jS r )r r r r )r Z stop_timer r r �stop8 s zStopwatch.stopc C s t j �� | j }| j| S r )r r r r )r Zlocal_durationr r r �split> s zStopwatch.splitc C s | � � | S r )r r r r r � __enter__C s zStopwatch.__enter__c C s | � � d S r )r )r �exc_type� exc_value� tracebackr r r �__exit__G s zStopwatch.__exit__N) �__name__� __module__� __qualname__�__doc__r r r r r r r r r r r r s r c @ s$ e Zd ZdZdd� Zdd� ZeZdS )�IntervalGovernorz� Decorate a function to only allow it to be called once per min_interval. Otherwise, it returns None. >>> gov = IntervalGovernor(30) >>> gov.min_interval.total_seconds() 30.0 c C s( t |tj�r tj|d�}|| _d | _d S )N)�seconds)� isinstance�numbers�Numberr r � min_interval� last_call)r r% r r r r U s zIntervalGovernor.__init__c s t �� �� �fdd��}|S )Nc s6 �j p �j �� �jk}|rt� �_ � | i |��S d S r )r& r r% r )�args�kwargsZallow��funcr r r �wrapper\ s �z*IntervalGovernor.decorate.<locals>.wrapper)� functools�wraps)r r* r+ r r) r �decorate[ s zIntervalGovernor.decorateN)r r r r r r. �__call__r r r r r K s r c s< e Zd ZdZed�f� fdd� Zedd� �Zdd� Z� Z S ) �Timerz� Watch for a target elapsed time. >>> t = Timer(0.1) >>> t.expired() False >>> __import__('time').sleep(0.15) >>> t.expired() True �Infc s | � |�| _tt| ��� d S r )�_accept�target�superr0 r )r r3 �� __class__r r r t s zTimer.__init__c C s( t | tj�r | �� } | du rtd�} | S )u� Accept None or ∞ or datetime or numeric for target >>> Timer._accept(datetime.timedelta(seconds=30)) 30.0 >>> Timer._accept(None) inf Nr1 )r" r r � total_seconds�float)r3 r r r r2 x s z Timer._acceptc C s | � � �� | jkS r )r r7 r3 r r r r �expired� � z Timer.expired) r r r r r8 r � staticmethodr2 r9 � __classcell__r r r5 r r0 h s r0 c @ sf e Zd ZdZdZdZ dZ ejj dde d�dfdd��Z dd� Z d d � Z d d � Zd d� Zdd� ZdS )� BackoffDelaya� Exponential backoff delay. Useful for defining delays between retries. Consider for use with ``jaraco.functools.retry_call`` as the cleanup. Default behavior has no effect; a delay or jitter must be supplied for the call to be non-degenerate. >>> bd = BackoffDelay() >>> bd() >>> bd() The following instance will delay 10ms for the first call, 20ms for the second, etc. >>> bd = BackoffDelay(delay=0.01, factor=2) >>> bd() >>> bd() Inspect and adjust the state of the delay anytime. >>> bd.delay 0.04 >>> bd.delay = 0.01 Set limit to prevent the delay from exceeding bounds. >>> bd = BackoffDelay(delay=0.01, factor=2, limit=0.015) >>> bd() >>> bd.delay 0.015 To reset the backoff, simply call ``.reset()``: >>> bd.reset() >>> bd.delay 0.01 Iterate on the object to retrieve/advance the delay values. >>> next(bd) 0.01 >>> next(bd) 0.015 >>> import itertools >>> tuple(itertools.islice(bd, 3)) (0.015, 0.015, 0.015) Limit may be a callable taking a number and returning the limited number. >>> at_least_one = lambda n: max(n, 1) >>> bd = BackoffDelay(delay=0.01, factor=2, limit=at_least_one) >>> next(bd) 0.01 >>> next(bd) 1 Pass a jitter to add or subtract seconds to the delay. >>> bd = BackoffDelay(jitter=0.01) >>> next(bd) 0 >>> next(bd) 0.01 Jitter may be a callable. To supply a non-deterministic jitter between -0.5 and 0.5, consider: >>> import random >>> jitter=functools.partial(random.uniform, -0.5, 0.5) >>> bd = BackoffDelay(jitter=jitter) >>> next(bd) 0 >>> 0 <= next(bd) <= 0.5 True r � �infc sT || _ || _t|tj�r|��fdd�}|| _t|tj�r%|� � fdd�}|| _d S )Nc s t dt� | ��S r )�max�min)�n)�limit_r r �limit� r z$BackoffDelay.__init__.<locals>.limitc s � S r r r )�jitter_r r �jitter� � z%BackoffDelay.__init__.<locals>.jitter)�delay�factorr" r# r$ rD rF )r rH rI rD rF r )rE rC r r � s zBackoffDelay.__init__c C s t �t| �� d S r )�time�sleep�nextr r r r r/ � r: zBackoffDelay.__call__c C s | j }| �� |S r )rH �bump)r rH r r r �__next__� s zBackoffDelay.__next__c C s | S r r r r r r �__iter__ rG zBackoffDelay.__iter__c C s | � | j| j | �� �| _d S r )rD rH rI rF r r r r rM s zBackoffDelay.bumpc C s | j }| j|ji |j�� d S r )Z_saved___init__r r' r( )r Zsavedr r r r s zBackoffDelay.resetN)r r r r rH rI rF �jaracor, Zsave_method_argsr8 r r/ rN rO rM r r r r r r= � s O r= )r r, r# rJ �collections.abc� collectionsr Zjaraco.functoolsrP r r r0 �abc�Iteratorr= r r r r �<module> s @ '
Save