Skip to content

Commit a937e2c

Browse files
author
octavia-squidington-iii
committed
Auto-fix lint and format issues
1 parent ad606dc commit a937e2c

File tree

3 files changed

+3
-5
lines changed

3 files changed

+3
-5
lines changed

airbyte_cdk/sources/streams/http/http.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -546,7 +546,7 @@ def _fetch_next_page(
546546
dedupe_query_params=True,
547547
log_formatter=self.get_log_formatter(),
548548
exit_on_rate_limit=self.exit_on_rate_limit,
549-
stream_slice=stream_slice
549+
stream_slice=stream_slice,
550550
)
551551

552552
return request, response

airbyte_cdk/sources/streams/http/http_client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -528,7 +528,7 @@ def send_request(
528528
request_kwargs=request_kwargs,
529529
log_formatter=log_formatter,
530530
exit_on_rate_limit=exit_on_rate_limit,
531-
stream_slice=stream_slice
531+
stream_slice=stream_slice,
532532
)
533533

534534
return request, response

airbyte_cdk/sources/streams/http/rate_limiting.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -118,9 +118,7 @@ def sleep_on_ratelimit(details: Mapping[str, Any]) -> None:
118118
logging_message = f"Retrying. Sleeping for {retry_after} seconds at {time.strftime('%Y-%m-%d %H:%M:%S')}"
119119
if stream_slice:
120120
logging_message += f" for slice: {stream_slice}"
121-
logger.info(
122-
logging_message
123-
)
121+
logger.info(logging_message)
124122
time.sleep(retry_after + 1) # extra second to cover any fractions of second
125123

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

0 commit comments

Comments
 (0)