format

Author: pnilan

airbyte_cdk/sources/declarative/declarative_component_schema.yaml

@@ -42,8 +42,10 @@ properties:
     "$ref": "#/definitions/ConcurrencyLevel"
   api_budget:
     "$ref": "#/definitions/HTTPAPIBudget"
-  max_concurrent_async_jobs:
-    "$ref": "#/definitions/MaxConcurrentAsyncJobs"
+  max_concurrent_job_count:
+    title: Maximum Concurrent Async Jobs
+    description: Maximum number of concurrent async jobs to run. This is often set by the API's maximum number of concurrent jobs on the account level.
+    type: integer
   metadata:
     type: object
     description: For internal Airbyte use only - DO NOT modify manually. Used by consumers of declarative manifests for storing related metadata.
@@ -2408,17 +2410,6 @@ definitions:
       $parameters:
         type: object
         additionalProperties: true
-  MaxConcurrentAsyncJobs:
-    title: Maximum Concurrent Async Jobs
-    description: Maximum number of concurrent async jobs to run. This is often set by the API's maximum number of concurrent jobs on the account level.
-    type: object
-    required:
-      - max_concurrent_job_count
-    properties:
-      max_concurrent_job_count:
-        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
   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/models/declarative_component_schema.py

@@ -929,14 +929,6 @@ class Config:
     parameters: Optional[Dict[str, Any]] = Field(None, alias="$parameters")
 
 
-class MaxConcurrentAsyncJobs(BaseModel):
-    max_concurrent_job_count: int = Field(
-        ...,
-        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.",
-        title="Maximum Concurrent Job Count",
-    )
-
-
 class MinMaxDatetime(BaseModel):
     type: Literal["MinMaxDatetime"]
     datetime: str = Field(
@@ -1879,7 +1871,11 @@ class Config:
     spec: Optional[Spec] = None
     concurrency_level: Optional[ConcurrencyLevel] = None
     api_budget: Optional[HTTPAPIBudget] = None
-    max_concurrent_async_jobs: Optional[MaxConcurrentAsyncJobs] = None
+    max_concurrent_job_count: Optional[int] = Field(
+        None,
+        description="Maximum number of concurrent async jobs to run. This is often set by the API's maximum number of concurrent jobs on the account level.",
+        title="Maximum Concurrent Async Jobs",
+    )
     metadata: Optional[Dict[str, Any]] = Field(
         None,
         description="For internal Airbyte use only - DO NOT modify manually. Used by consumers of declarative manifests for storing related metadata.",
@@ -1907,7 +1903,11 @@ class Config:
     spec: Optional[Spec] = None
     concurrency_level: Optional[ConcurrencyLevel] = None
     api_budget: Optional[HTTPAPIBudget] = None
-    max_concurrent_async_jobs: Optional[MaxConcurrentAsyncJobs] = None
+    max_concurrent_job_count: Optional[int] = Field(
+        None,
+        description="Maximum number of concurrent async jobs to run. This is often set by the API's maximum number of concurrent jobs on the account level.",
+        title="Maximum Concurrent Async Jobs",
+    )
     metadata: Optional[Dict[str, Any]] = Field(
         None,
         description="For internal Airbyte use only - DO NOT modify manually. Used by consumers of declarative manifests for storing related metadata.",