From 1d1f58eb57372972326e441100a2e3c7b380e33c Mon Sep 17 00:00:00 2001
From: Alexandros Milaios <alexmilaios@gmail.com>
Date: Thu, 3 Oct 2024 16:06:43 +0300
Subject: [PATCH] fix: increase the number of requests per second

---
 .../connectors/source-recurly/source_recurly/streams.py    | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/airbyte-integrations/connectors/source-recurly/source_recurly/streams.py b/airbyte-integrations/connectors/source-recurly/source_recurly/streams.py
index e95dace10eee..0ae4098f853b 100644
--- a/airbyte-integrations/connectors/source-recurly/source_recurly/streams.py
+++ b/airbyte-integrations/connectors/source-recurly/source_recurly/streams.py
@@ -18,6 +18,7 @@
 
 BEGIN_TIME_PARAM = "begin_time"
 END_TIME_PARAM = "end_time"
+RATE_LIMIT_SLEEP_IN_SECS = 0.16
 
 CAMEL_CASE_PATTERN = re.compile(r"(?<!^)(?=[A-Z])")
 
@@ -138,7 +139,7 @@ def read_records(
             # slow down the API calls to avoid rate limiting
             # https://recurly.com/developers/api-v2/v2.2/#section/Rate-Limits
             # making 5 API calls per second / 300 API calls per minute / 1500 API calls per 5 minutes
-            time.sleep(0.2)
+            time.sleep(RATE_LIMIT_SLEEP_IN_SECS)
 
     def get_updated_state(self, current_stream_state: MutableMapping[str, Any], latest_record: Mapping[str, Any]):
         """
@@ -216,7 +217,7 @@ def read_records(
                     for item in page:
                         yield self._item_to_dict(item)
                     # slow down the API calls to avoid rate limiting
-                    time.sleep(0.2)
+                    time.sleep(RATE_LIMIT_SLEEP_IN_SECS)
         except MissingFeatureError as error:
             super().logger.warning(f"Missing feature error {error}")
 
@@ -343,6 +344,6 @@ def read_records(
                 for item in page:
                     yield self._item_to_dict(item)
                 # slow down the API calls to avoid rate limiting
-                time.sleep(0.2)
+                time.sleep(RATE_LIMIT_SLEEP_IN_SECS)
             except (NotFoundError, ValidationError):
                 pass