Skip to content

Commit d6c6846

Browse files
author
octavia-squidington-iii
committed
Auto-fix lint and format issues
1 parent 8ff11cf commit d6c6846

File tree

2 files changed

+10
-5
lines changed

2 files changed

+10
-5
lines changed

airbyte_cdk/sources/streams/http/http_client.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -259,9 +259,9 @@ def _send_with_retry(
259259
max_tries = max(0, max_retries) + 1
260260
max_time = self._max_time
261261

262-
user_backoff_handler = user_defined_backoff_handler(max_tries=max_tries, max_time=max_time, request_url=request.url)(
263-
self._send
264-
)
262+
user_backoff_handler = user_defined_backoff_handler(
263+
max_tries=max_tries, max_time=max_time, request_url=request.url
264+
)(self._send)
265265
rate_limit_backoff_handler = rate_limit_default_backoff_handler(max_tries=max_tries)
266266
backoff_handler = http_client_default_backoff_handler(
267267
max_tries=max_tries, max_time=max_time

airbyte_cdk/sources/streams/http/rate_limiting.py

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -101,7 +101,10 @@ def should_give_up(exc: Exception) -> bool:
101101

102102

103103
def user_defined_backoff_handler(
104-
max_tries: Optional[int], max_time: Optional[int] = None, request_url: Optional[str] = None, **kwargs: Any
104+
max_tries: Optional[int],
105+
max_time: Optional[int] = None,
106+
request_url: Optional[str] = None,
107+
**kwargs: Any,
105108
) -> Callable[[SendRequestCallableType], SendRequestCallableType]:
106109
def sleep_on_ratelimit(details: Mapping[str, Any]) -> None:
107110
_, exc, _ = sys.exc_info()
@@ -112,7 +115,9 @@ def sleep_on_ratelimit(details: Mapping[str, Any]) -> None:
112115
)
113116
retry_after = exc.backoff
114117
# include logging og the current time to help with debugging
115-
logger.info(f"Retrying. Sleeping for {retry_after} seconds at {time.strftime('%Y-%m-%d %H:%M:%S')} for URL: {request_url or 'unknown'}")
118+
logger.info(
119+
f"Retrying. Sleeping for {retry_after} seconds at {time.strftime('%Y-%m-%d %H:%M:%S')} for URL: {request_url or 'unknown'}"
120+
)
116121
time.sleep(retry_after + 1) # extra second to cover any fractions of second
117122

118123
def log_give_up(details: Mapping[str, Any]) -> None:

0 commit comments

Comments
 (0)