clean

Author: pnilan

airbyte_cdk/sources/declarative/async_job/job_tracker.py

@@ -15,9 +15,9 @@ class ConcurrentJobLimitReached(Exception):
 
 
 class JobTracker:
-    def __init__(self, limit: Optional[int]):
+    def __init__(self, limit: int):
         self._jobs: Set[str] = set()
-        self._limit = limit if isinstance(limit, int) and limit >= 1 else 1
+        self._limit = 1 if limit < 1 else limit
         self._lock = threading.Lock()
 
     def try_to_get_intent(self) -> str:

airbyte_cdk/sources/declarative/declarative_component_schema.yaml

@@ -2419,7 +2419,6 @@ definitions:
         title: Maximum Concurrent Job Count
         description: Maximum number of concurrent jobs to run. This is often set by the API's maximum number of concurrent jobs on the account level.
         type: integer
-        default: 1
   MinMaxDatetime:
     title: Min-Max Datetime
     description: Compares the provided date against optional minimum or maximum times. The max_datetime serves as the ceiling and will be returned when datetime exceeds it. The min_datetime serves as the floor.

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

@@ -541,7 +541,7 @@ def __init__(
         )
         self._connector_state_manager = connector_state_manager or ConnectorStateManager()
         self._api_budget: Optional[Union[APIBudget, HttpAPIBudget]] = None
-        self._job_tracker: Optional[JobTracker] = self._set_max_concurrent_async_job_count(
+        self._job_tracker: Optional[JobTracker] = self._create_async_job_tracker(
             source_config=source_config
         )
 
@@ -3225,7 +3225,7 @@ def set_api_budget(self, component_definition: ComponentDefinition, config: Conf
             model_type=HTTPAPIBudgetModel, component_definition=component_definition, config=config
         )
 
-    def _set_max_concurrent_async_job_count(
+    def _create_async_job_tracker(
         self, source_config: ConnectionDefinition
     ) -> Optional[JobTracker]:
         """