update per comments

Author: pnilan

airbyte_cdk/sources/declarative/async_job/job_tracker.py

@@ -17,6 +17,10 @@ class ConcurrentJobLimitReached(Exception):
 class JobTracker:
     def __init__(self, limit: int):
         self._jobs: Set[str] = set()
+        if limit < 1:
+            LOGGER.warning(
+                f"The `max_concurrent_async_job_count` property is less than 1: {limit}. Setting to 1. Please update the source manifest to set a valid value."
+            )
         self._limit = 1 if limit < 1 else limit
         self._lock = threading.Lock()
 

airbyte_cdk/sources/declarative/declarative_component_schema.yaml

@@ -43,8 +43,8 @@ properties:
   api_budget:
     "$ref": "#/definitions/HTTPAPIBudget"
   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.
+    title: Maximum Concurrent Asynchronous Jobs
+    description: Maximum number of concurrent asynchronous jobs to run. This property is only relevant for sources/streams that support asynchronous job execution through the AsyncRetriever (e.g. a report-based stream 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. Refer to the API's documentation for this information.
     type: integer
   metadata:
     type: object

airbyte_cdk/sources/declarative/models/declarative_component_schema.py

@@ -1873,8 +1873,8 @@ class Config:
     api_budget: Optional[HTTPAPIBudget] = None
     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",
+        description="Maximum number of concurrent asynchronous jobs to run. This property is only relevant for sources/streams that support asynchronous job execution through the AsyncRetriever (e.g. a report-based stream 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. Refer to the API's documentation for this information.",
+        title="Maximum Concurrent Asynchronous Jobs",
     )
     metadata: Optional[Dict[str, Any]] = Field(
         None,
@@ -1905,8 +1905,8 @@ class Config:
     api_budget: Optional[HTTPAPIBudget] = None
     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",
+        description="Maximum number of concurrent asynchronous jobs to run. This property is only relevant for sources/streams that support asynchronous job execution through the AsyncRetriever (e.g. a report-based stream 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. Refer to the API's documentation for this information.",
+        title="Maximum Concurrent Asynchronous Jobs",
     )
     metadata: Optional[Dict[str, Any]] = Field(
         None,