Skip to content

Commit a71c505

Browse files
committed
reduce logging
1 parent d6c6846 commit a71c505

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

airbyte_cdk/sources/streams/http/http_client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -260,7 +260,7 @@ def _send_with_retry(
260260
max_time = self._max_time
261261

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

airbyte_cdk/sources/streams/http/rate_limiting.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,6 @@ def should_give_up(exc: Exception) -> bool:
103103
def user_defined_backoff_handler(
104104
max_tries: Optional[int],
105105
max_time: Optional[int] = None,
106-
request_url: Optional[str] = None,
107106
**kwargs: Any,
108107
) -> Callable[[SendRequestCallableType], SendRequestCallableType]:
109108
def sleep_on_ratelimit(details: Mapping[str, Any]) -> None:
@@ -116,7 +115,7 @@ def sleep_on_ratelimit(details: Mapping[str, Any]) -> None:
116115
retry_after = exc.backoff
117116
# include logging og the current time to help with debugging
118117
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'}"
118+
f"Retrying. Sleeping for {retry_after} seconds at {time.strftime('%Y-%m-%d %H:%M:%S')}"
120119
)
121120
time.sleep(retry_after + 1) # extra second to cover any fractions of second
122121

0 commit comments

Comments
 (0)