diff --git a/airbyte-cdk/python/airbyte_cdk/sources/streams/call_rate.py b/airbyte-cdk/python/airbyte_cdk/sources/streams/call_rate.py
index 905489dfbb4f..eb33754504ee 100644
--- a/airbyte-cdk/python/airbyte_cdk/sources/streams/call_rate.py
+++ b/airbyte-cdk/python/airbyte_cdk/sources/streams/call_rate.py
@@ -375,11 +375,12 @@ def update_from_response(self, request: Any, response: Any) -> None:
 class APIBudget(AbstractAPIBudget):
     """Default APIBudget implementation"""
 
-    def __init__(self, policies: list[AbstractCallRatePolicy], maximum_attempts_to_acquire: int = 10) -> None:
+    def __init__(self, policies: list[AbstractCallRatePolicy], maximum_attempts_to_acquire: int = 100000) -> None:
         """Constructor
 
         :param policies: list of policies in this budget
-        :param maximum_attempts_to_acquire: number of attempts before throwing hit ratelimit exception
+        :param maximum_attempts_to_acquire: number of attempts before throwing hit ratelimit exception, we put some big number here
+         to avoid situations when many threads compete with each other for a few lots over a significant amount of time
         """
 
         self._policies = policies