43
43
"_retry_delay_max" : (float , 60 , 5 , 3600 ),
44
44
"_retry_stop_after_attempts_count" : (int , 30 , 1 , 60 ),
45
45
"_retry_stop_after_attempts_duration" : (float , 900 , 1 , 86400 ),
46
- "_retry_delay_default" : (float , 5 , 1 , 60 )
46
+ "_retry_delay_default" : (float , 5 , 1 , 60 ),
47
47
}
48
48
49
49
@@ -77,7 +77,7 @@ def __init__(
77
77
# _retry_delay_max (default: 60)
78
78
# {min,max} pre-retry delay bounds
79
79
# _retry_delay_default (default: 5)
80
- # Only used when GetOperationStatus fails due to a TCP/OS Error.
80
+ # Only used when GetOperationStatus fails due to a TCP/OS Error.
81
81
# _retry_stop_after_attempts_count (default: 30)
82
82
# total max attempts during retry sequence
83
83
# _retry_stop_after_attempts_duration (default: 900)
@@ -270,8 +270,7 @@ def get_elapsed():
270
270
return time .time () - t0
271
271
272
272
def bound_retry_delay (attempt , proposed_delay ):
273
- """bound delay (seconds) by [min_delay*1.5^(attempt-1), max_delay]
274
- """
273
+ """bound delay (seconds) by [min_delay*1.5^(attempt-1), max_delay]"""
275
274
delay = int (proposed_delay )
276
275
delay = max (delay , self ._retry_delay_min * math .pow (1.5 , attempt - 1 ))
277
276
delay = min (delay , self ._retry_delay_max )
@@ -293,7 +292,7 @@ def attempt_request(attempt):
293
292
# - non-None method_return -> success, return and be done
294
293
# - non-None retry_delay -> sleep delay before retry
295
294
# - error, error_message always set when available
296
-
295
+
297
296
error , error_message , retry_delay = None , None , None
298
297
try :
299
298
logger .debug ("Sending request: {}" .format (request ))
0 commit comments