chore: sync unified package v0.1.29

Source: airbyte-embedded@da34f6ce1

Author: github-actions[bot]

airbyte_agent_sdk/connector_model_loader.py

@@ -502,6 +502,9 @@ def convert_openapi_to_connector_model(spec: OpenAPIConnector) -> ConnectorModel
             # Extract untested flag
             untested = getattr(operation, "x_airbyte_untested", None) or False
 
+            # Extract x-airbyte-no-pagination justification (list-action opt-out)
+            no_pagination = getattr(operation, "x_airbyte_no_pagination", None)
+
             # Extract preferred_for_check flag
             preferred_for_check = getattr(operation, "x_airbyte_preferred_for_check", None) or False
 
@@ -532,14 +535,11 @@ def convert_openapi_to_connector_model(spec: OpenAPIConnector) -> ConnectorModel
                 graphql_body=graphql_body,
                 file_field=file_field,
                 untested=untested,
+                no_pagination=no_pagination,
                 preferred_for_check=preferred_for_check,
                 upload_file_param=upload_file_param,
                 no_content_response=has_no_content_response,
-                ai_hints=(
-                    operation.x_airbyte_ai_hints.model_dump(by_alias=True)
-                    if operation.x_airbyte_ai_hints is not None
-                    else None
-                ),
+                ai_hints=(operation.x_airbyte_ai_hints.model_dump(by_alias=True) if operation.x_airbyte_ai_hints is not None else None),
             )
 
             # Add to entities map

airbyte_agent_sdk/connectors/airtable/connector.py

@@ -97,7 +97,7 @@ class AirtableConnector:
 
     connector_name = "airtable"
     connector_version = "1.0.8"
-    sdk_version = "0.1.28"
+    sdk_version = "0.1.29"
 
     # Map of (entity, action) -> needs_envelope for envelope wrapping decision
     _ENVELOPE_MAP = {
@@ -618,7 +618,8 @@ async def list(
         result = await self._connector.execute("bases", "list", params)
         # Cast generic envelope to concrete typed result
         return BasesListResult(
-            data=result.data
+            data=result.data,
+            meta=result.meta
         )
 
 
@@ -826,7 +827,8 @@ async def list(
         result = await self._connector.execute("records", "list", params)
         # Cast generic envelope to concrete typed result
         return RecordsListResult(
-            data=result.data
+            data=result.data,
+            meta=result.meta
         )
 
 

airbyte_agent_sdk/connectors/airtable/connector_model.py

@@ -99,6 +99,7 @@
                         },
                     },
                     record_extractor='$.bases',
+                    meta_extractor={'offset': '$.offset'},
                 ),
             },
             entity_schema={
@@ -211,6 +212,7 @@
                         },
                     },
                     record_extractor='$.tables',
+                    no_pagination='Airtable Metadata API returns all tables for a base in a single response with no pagination support.',
                 ),
             },
             entity_schema={
@@ -311,6 +313,7 @@
                         },
                     },
                     record_extractor='$.records',
+                    meta_extractor={'offset': '$.offset'},
                 ),
                 Action.GET: EndpointDefinition(
                     method='GET',

airbyte_agent_sdk/connectors/airtable/models.py

@@ -37,22 +37,22 @@ class BasesList(BaseModel):
     bases: Union[list[Base], Any] = Field(default=None)
     offset: Union[str | None, Any] = Field(default=None)
 
-class View(BaseModel):
-    """A view in a table"""
+class TableField(BaseModel):
+    """A field (column) in a table"""
     model_config = ConfigDict(extra="allow", populate_by_name=True)
 
     id: Union[str | None, Any] = Field(default=None)
     name: Union[str | None, Any] = Field(default=None)
     type_: Union[str | None, Any] = Field(default=None, alias="type")
+    options: Union[dict[str, Any] | None, Any] = Field(default=None)
 
-class TableField(BaseModel):
-    """A field (column) in a table"""
+class View(BaseModel):
+    """A view in a table"""
     model_config = ConfigDict(extra="allow", populate_by_name=True)
 
     id: Union[str | None, Any] = Field(default=None)
     name: Union[str | None, Any] = Field(default=None)
     type_: Union[str | None, Any] = Field(default=None, alias="type")
-    options: Union[dict[str, Any] | None, Any] = Field(default=None)
 
 class Table(BaseModel):
     """A table within an Airtable base"""
@@ -88,6 +88,18 @@ class RecordsList(BaseModel):
 # ===== METADATA TYPE DEFINITIONS (PYDANTIC) =====
 # Meta types for operations that extract metadata (e.g., pagination info)
 
+class BasesListResultMeta(BaseModel):
+    """Metadata for bases.Action.LIST operation"""
+    model_config = ConfigDict(extra="allow", populate_by_name=True)
+
+    offset: Union[str | None, Any] = Field(default=None)
+
+class RecordsListResultMeta(BaseModel):
+    """Metadata for records.Action.LIST operation"""
+    model_config = ConfigDict(extra="allow", populate_by_name=True)
+
+    offset: Union[str | None, Any] = Field(default=None)
+
 # ===== CHECK RESULT MODEL =====
 
 class AirtableCheckResult(BaseModel):
@@ -206,12 +218,12 @@ class AirbyteSearchResult(BaseModel, Generic[D]):
 # Concrete type aliases for each operation result.
 # These provide simpler, more readable type annotations than using the generic forms.
 
-BasesListResult = AirtableExecuteResult[list[Base]]
-"""Result type for bases.list operation."""
+BasesListResult = AirtableExecuteResultWithMeta[list[Base], BasesListResultMeta]
+"""Result type for bases.list operation with data and metadata."""
 
 TablesListResult = AirtableExecuteResult[list[Table]]
 """Result type for tables.list operation."""
 
-RecordsListResult = AirtableExecuteResult[list[Record]]
-"""Result type for records.list operation."""
+RecordsListResult = AirtableExecuteResultWithMeta[list[Record], RecordsListResultMeta]
+"""Result type for records.list operation with data and metadata."""
 

airbyte_agent_sdk/connectors/amazon_ads/connector.py

@@ -120,7 +120,7 @@ class AmazonAdsConnector:
 
     connector_name = "amazon-ads"
     connector_version = "1.0.10"
-    sdk_version = "0.1.28"
+    sdk_version = "0.1.29"
 
     # Map of (entity, action) -> needs_envelope for envelope wrapping decision
     _ENVELOPE_MAP = {
@@ -994,7 +994,8 @@ async def list(
         result = await self._connector.execute("portfolios", "list", params)
         # Cast generic envelope to concrete typed result
         return PortfoliosListResult(
-            data=result.data
+            data=result.data,
+            meta=result.meta
         )
 
 
@@ -1065,7 +1066,8 @@ async def list(
         result = await self._connector.execute("sponsored_product_campaigns", "list", params)
         # Cast generic envelope to concrete typed result
         return SponsoredProductCampaignsListResult(
-            data=result.data
+            data=result.data,
+            meta=result.meta
         )
 
 
@@ -1136,7 +1138,8 @@ async def list(
         result = await self._connector.execute("sponsored_product_ad_groups", "list", params)
         # Cast generic envelope to concrete typed result
         return SponsoredProductAdGroupsListResult(
-            data=result.data
+            data=result.data,
+            meta=result.meta
         )
 
 
@@ -1181,7 +1184,8 @@ async def list(
         result = await self._connector.execute("sponsored_product_keywords", "list", params)
         # Cast generic envelope to concrete typed result
         return SponsoredProductKeywordsListResult(
-            data=result.data
+            data=result.data,
+            meta=result.meta
         )
 
 
@@ -1226,7 +1230,8 @@ async def list(
         result = await self._connector.execute("sponsored_product_product_ads", "list", params)
         # Cast generic envelope to concrete typed result
         return SponsoredProductProductAdsListResult(
-            data=result.data
+            data=result.data,
+            meta=result.meta
         )
 
 
@@ -1271,7 +1276,8 @@ async def list(
         result = await self._connector.execute("sponsored_product_targets", "list", params)
         # Cast generic envelope to concrete typed result
         return SponsoredProductTargetsListResult(
-            data=result.data
+            data=result.data,
+            meta=result.meta
         )
 
 
@@ -1316,7 +1322,8 @@ async def list(
         result = await self._connector.execute("sponsored_product_negative_keywords", "list", params)
         # Cast generic envelope to concrete typed result
         return SponsoredProductNegativeKeywordsListResult(
-            data=result.data
+            data=result.data,
+            meta=result.meta
         )
 
 
@@ -1361,7 +1368,8 @@ async def list(
         result = await self._connector.execute("sponsored_product_negative_targets", "list", params)
         # Cast generic envelope to concrete typed result
         return SponsoredProductNegativeTargetsListResult(
-            data=result.data
+            data=result.data,
+            meta=result.meta
         )
 
 
@@ -1406,7 +1414,8 @@ async def list(
         result = await self._connector.execute("sponsored_brands_campaigns", "list", params)
         # Cast generic envelope to concrete typed result
         return SponsoredBrandsCampaignsListResult(
-            data=result.data
+            data=result.data,
+            meta=result.meta
         )
 
 
@@ -1451,7 +1460,8 @@ async def list(
         result = await self._connector.execute("sponsored_brands_ad_groups", "list", params)
         # Cast generic envelope to concrete typed result
         return SponsoredBrandsAdGroupsListResult(
-            data=result.data
+            data=result.data,
+            meta=result.meta
         )
 
 

airbyte_agent_sdk/connectors/amazon_ads/connector_model.py

@@ -174,6 +174,7 @@
                             },
                         },
                     },
+                    no_pagination='The Amazon Ads /v2/profiles endpoint returns the full list of advertising profiles associated with the authenticated user as a single JSON array; there is no pagination cursor.',
                     preferred_for_check=True,
                 ),
                 Action.GET: EndpointDefinition(
@@ -465,6 +466,7 @@
                             },
                         },
                     },
+                    meta_extractor={'next_token': '$.nextToken'},
                 ),
                 Action.GET: EndpointDefinition(
                     method='GET',
@@ -900,6 +902,7 @@
                             },
                         },
                     },
+                    meta_extractor={'next_token': '$.nextToken'},
                 ),
                 Action.GET: EndpointDefinition(
                     method='GET',
@@ -1354,6 +1357,7 @@
                             },
                         },
                     },
+                    meta_extractor={'next_token': '$.nextToken'},
                 ),
             },
             entity_schema={
@@ -1568,6 +1572,7 @@
                             },
                         },
                     },
+                    meta_extractor={'next_token': '$.nextToken'},
                 ),
             },
             entity_schema={
@@ -1789,6 +1794,7 @@
                             },
                         },
                     },
+                    meta_extractor={'next_token': '$.nextToken'},
                 ),
             },
             entity_schema={
@@ -2032,6 +2038,7 @@
                             },
                         },
                     },
+                    meta_extractor={'next_token': '$.nextToken'},
                 ),
             },
             entity_schema={
@@ -2280,6 +2287,7 @@
                             },
                         },
                     },
+                    meta_extractor={'next_token': '$.nextToken'},
                 ),
             },
             entity_schema={
@@ -2523,6 +2531,7 @@
                             },
                         },
                     },
+                    meta_extractor={'next_token': '$.nextToken'},
                 ),
             },
             entity_schema={
@@ -2793,6 +2802,7 @@
                             },
                         },
                     },
+                    meta_extractor={'next_token': '$.nextToken'},
                 ),
             },
             entity_schema={
@@ -3019,6 +3029,7 @@
                             },
                         },
                     },
+                    meta_extractor={'next_token': '$.nextToken'},
                 ),
             },
             entity_schema={