Skip to content

Commit 907c932

Browse files
author
yuguo.dtpe
committed
fix: fix code style
1 parent 08e37db commit 907c932

File tree

5 files changed

+16
-11
lines changed

5 files changed

+16
-11
lines changed

volcenginesdkcore/api_client.py

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -17,10 +17,10 @@
1717
from volcenginesdkcore.interceptor import DeserializedResponseInterceptor
1818
from volcenginesdkcore.interceptor import InterceptorChain, InterceptorContext
1919
from volcenginesdkcore.interceptor import Request, Response
20-
from volcenginesdkcore.retryer.retryer import DEFAULT_RETRYER
2120

2221
logger = logging.getLogger(__name__)
2322

23+
2424
class ApiClient(object):
2525
"""Generic API client for Swagger client library builds.
2626
@@ -171,8 +171,10 @@ def request_retry(self, response_data, retry_count, retry_err, retryer):
171171
delay = retryer.get_backoff_delay(retry_count)
172172
sleep(delay / 1000)
173173
if self.configuration.debug:
174-
logger.debug("retry backoff strategy:%s, retry condition: %s, max retry count:%d, current retry count: %d, retry delay(ms):%f",
175-
type(retryer.backoff_strategy).__name__,type(retryer.retry_condition).__name__, retryer.num_max_retries, retry_count + 1, delay)
174+
logger.debug(
175+
"retry backoff strategy:%s, retry condition: %s, max retry count:%d, current retry count: %d, retry delay(ms):%f",
176+
type(retryer.backoff_strategy).__name__, type(retryer.retry_condition).__name__,
177+
retryer.num_max_retries, retry_count + 1, delay)
176178
return True
177179
return False
178180

volcenginesdkcore/interceptor/interceptors/request.py

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,3 @@
1-
from volcenginesdkcore.retryer.retryer import DefaultRetryCondition, ExponentialWithRandomJitterBackoffStrategy
2-
3-
41
class RuntimeOption(object):
52
def __init__(self, client_side_validation, ak=None, sk=None, session_token=None, region=None, scheme=None,
63
endpoint_provider=None, connect_timeout=None, read_timeout=None, auto_retry=None, num_max_retries=None,

volcenginesdkcore/interceptor/interceptors/runtime_options_interceptor.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,4 +53,4 @@ def __update_retryer(context, opt):
5353
context.request.retryer.backoff_strategy.max_retry_delay_ms = max_retry_delay_ms
5454
context.request.retryer.retry_condition = opt.retry_condition \
5555
if opt.retry_condition is not None else context.request.retryer.retry_condition
56-
context.request.retryer.retry_condition.retry_error_codes = retry_error_codes
56+
context.request.retryer.retry_condition.retry_error_codes = retry_error_codes

volcenginesdkcore/retryer/backoff_strategy.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@
55

66
from volcenginesdkcore.utils import six_utils
77

8+
89
class BackoffStrategy(six_utils.get_abstract_meta_class()):
910
"""
1011
Abstract base class for all backoff strategies.
@@ -25,7 +26,6 @@ def __init__(self,
2526
self.min_retry_delay_ms = min_retry_delay_ms
2627
self.max_retry_delay_ms = max_retry_delay_ms
2728

28-
2929
@abstractmethod
3030
def compute_delay(self, retry_count):
3131
# type: (int) -> float
@@ -74,6 +74,7 @@ def compute_delay(self, retry_count):
7474
delay = min(min_retry_delay_ms * (2 ** retry_count), max_retry_delay_ms)
7575
return delay
7676

77+
7778
class ExponentialWithRandomJitterBackoffStrategy(ExponentialBackoffStrategy):
7879
"""
7980
An exponential backoff strategy with random jitter.

volcenginesdkcore/retryer/retryer.py

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,12 @@
11
# coding: utf-8
2+
from typing import TYPE_CHECKING
3+
from volcenginesdkcore.retryer.backoff_strategy import ExponentialWithRandomJitterBackoffStrategy
4+
from volcenginesdkcore.retryer.retry_condition import DefaultRetryCondition
25

3-
from volcenginesdkcore.rest import RESTResponse
4-
from volcenginesdkcore.retryer.backoff_strategy import ExponentialWithRandomJitterBackoffStrategy, BackoffStrategy
5-
from volcenginesdkcore.retryer.retry_condition import DefaultRetryCondition, RetryCondition
6+
if TYPE_CHECKING:
7+
from volcenginesdkcore.rest import RESTResponse
8+
from volcenginesdkcore.retryer.backoff_strategy import BackoffStrategy
9+
from volcenginesdkcore.retryer.retry_condition import RetryCondition
610

711
_DEFAULT_BACKOFF_STRATEGY = ExponentialWithRandomJitterBackoffStrategy(
812
min_retry_delay_ms=300,
@@ -69,4 +73,5 @@ def get_backoff_delay(
6973
return self.backoff_strategy.compute_delay(retry_count)
7074
return 0.0
7175

76+
7277
DEFAULT_RETRYER = Retryer()

0 commit comments

Comments
 (0)