/
var
/
opt
/
nydus
/
ops
/
customer_local_ops
/
util
/
__pycache__
/
up file
home
� =�j` � � � d Z ddlmZ ddlmZmZ ddlmZ ddlZ ej e � Z G d� d� Z e � Z d d�Z y) u$ © Copyright. All rights reserved. � )�unicode_literals)�datetime� timedelta��wrapsNc � � e Zd ZdZdd�Zd� Zy)�Retryz�Ops decorated with @retry can return a Retry instance to request retry with the interval and timeout as specified in the decorator. See also the RETRY sentinel if there is no intermediate_result. Nc �d � |�'t |t � st dt |� z � �|| _ y )Nz7Retry intermediate_result must be dictionary but got %s)� isinstance�dict� TypeError�type�intermediate_result)�selfr s �N/opt/nydus/tmp/pip-target-hb7welcc/lib/python/customer_local_ops/util/retry.py�__init__zRetry.__init__ s> � �#�+��.��5�� )�+/�0C�+D� E� F� F�#6�� � c �2 � dt | j � z S )NzRetry )�str�__dict__)r s r �__str__z Retry.__str__ s � ��#�d�m�m�,�,�,r )N)�__name__� __module__� __qualname__�__doc__r r � r r r r s � �� 7�-r r c � � �� � �fd�}|S )z�Op decorator that returns a retry request to Nydus when the op returns a Retry instance. Op will be retried by Nydus after `interval` seconds. Returns failure at the specified timeout (seconds). c �4 �� � t � � �� �fd�� }|S )Nc � �� |j dd � }t j � }|xr |j d� xs |t � �� z }||k\ r6dj t � dd� � � }t j |� d|fS � | i |��}t |t � r'|j xs i }|j d|� d|�fS |S )Nr �timeout)�secondsz Timeout waiting for {} ({}s)r �?F) �getr �utcnowr �format�getattr�LOG�errorr r r � setdefault) �args�kwr �now� timeout_abs�msg�result�ir�interval�originalr s ���r �wrapperz$retry.<locals>.deco.<locals>.wrapper, s� �� �"$�&�&�)>��"E� ��/�/�#�C�.� >�.�2�2�9�=� <� ��7�!;�;� � �k�!�4�;�;�G�H�j�Z]�<^�`g�h��� � �#�� �c�z�!� �t�*�r�*�F��&�%�(��/�/�5�2��� � �i��5� �b�(�*�*��Mr r )r2 r3 r1 r s ` ��r �decozretry.<locals>.deco+ s �� � �x� � � � �* �r r )r1 r r4 s `` r �retryr5 % s �� � �0 �Kr )� �< )r � __future__r r r � functoolsr �logging� getLoggerr r' r �RETRYr5 r r r �<module>r= sB ��� (� (� � ��g����!��-� -�" ��� r