update property name and add simple test

Author: pnilan

airbyte_cdk/sources/declarative/declarative_component_schema.yaml

@@ -42,7 +42,7 @@ properties:
     "$ref": "#/definitions/ConcurrencyLevel"
   api_budget:
     "$ref": "#/definitions/HTTPAPIBudget"
-  max_concurrent_job_count:
+  max_concurrent_async_job_count:
     title: Maximum Concurrent Async Jobs
     description: Maximum number of concurrent async jobs to run. This property is only relevant for sources/streams that support asynchronous job execution (e.g. a Report stream that requires that initiates a job, polls the job status, and then fetches the job results). This is often set by the API's maximum number of concurrent jobs on the account level.
     type: integer

airbyte_cdk/sources/declarative/manifest_declarative_source.py

@@ -95,7 +95,7 @@ def __init__(
             if component_factory
             else ModelToComponentFactory(
                 emit_connector_builder_messages,
-                max_concurrent_async_job_count=source_config.get("max_concurrent_job_count"),
+                max_concurrent_async_job_count=source_config.get("max_concurrent_async_job_count"),
             )
         )
         self._message_repository = self._constructor.get_message_repository()

airbyte_cdk/sources/declarative/models/declarative_component_schema.py

@@ -1871,7 +1871,7 @@ class Config:
     spec: Optional[Spec] = None
     concurrency_level: Optional[ConcurrencyLevel] = None
     api_budget: Optional[HTTPAPIBudget] = None
-    max_concurrent_job_count: Optional[int] = Field(
+    max_concurrent_async_job_count: Optional[int] = Field(
         None,
         description="Maximum number of concurrent async jobs to run. This property is only relevant for sources/streams that support asynchronous job execution (e.g. a Report stream that requires that initiates a job, polls the job status, and then fetches the job results). This is often set by the API's maximum number of concurrent jobs on the account level.",
         title="Maximum Concurrent Async Jobs",
@@ -1903,7 +1903,7 @@ class Config:
     spec: Optional[Spec] = None
     concurrency_level: Optional[ConcurrencyLevel] = None
     api_budget: Optional[HTTPAPIBudget] = None
-    max_concurrent_job_count: Optional[int] = Field(
+    max_concurrent_async_job_count: Optional[int] = Field(
         None,
         description="Maximum number of concurrent async jobs to run. This property is only relevant for sources/streams that support asynchronous job execution (e.g. a Report stream that requires that initiates a job, polls the job status, and then fetches the job results). This is often set by the API's maximum number of concurrent jobs on the account level.",
         title="Maximum Concurrent Async Jobs",

unit_tests/sources/declarative/async_job/test_job_tracker.py

@@ -39,3 +39,9 @@ def test_given_limit_reached_when_add_job_then_limit_is_still_reached(self) -> N
 
     def _reach_limit(self) -> List[str]:
         return [self._tracker.try_to_get_intent() for i in range(_LIMIT)]
+
+
+@pytest.mark.parametrize("limit", [-1, 0])
+def test_given_limit_is_less_than_1_when_init_then_set_to_1(limit: int):
+    tracker = JobTracker(limit)
+    assert tracker._limit == 1