Merge pull request #2603 from airbytehq/publish/linkedin-ads-v0.1.5

chore(linkedin-ads): bump to 0.1.5

Author: octavia-bot-hoard[bot]

connectors/linkedin-ads/CHANGELOG.md

@@ -1,5 +1,10 @@
 # Linkedin Ads changelog
 
+## [0.1.5] - 2026-03-23
+- Updated connector definition (YAML version 1.0.1)
+- Source commit: 6ad04bc3
+- SDK version: 0.1.0
+
 ## [0.1.4] - 2026-03-23
 - Updated connector definition (YAML version 1.0.1)
 - Source commit: 5718dee3

connectors/linkedin-ads/README.md

@@ -115,7 +115,7 @@ See the official [Linkedin-Ads API reference](https://learn.microsoft.com/en-us/
 
 ## Version information
 
-- **Package version:** 0.1.4
+- **Package version:** 0.1.5
 - **Connector version:** 1.0.1
-- **Generated with Connector SDK commit SHA:** 5718dee300be8dbcbdece58f9474cf54625872e7
+- **Generated with Connector SDK commit SHA:** 6ad04bc3fb66fc474336c37d69c79fb843ea1609
 - **Changelog:** [View changelog](https://github.com/airbytehq/airbyte-agent-connectors/blob/main/connectors/linkedin-ads/CHANGELOG.md)

connectors/linkedin-ads/airbyte_agent_linkedin_ads/__init__.py

@@ -21,22 +21,22 @@
     AccountUser,
     AccountUsersListMetadata,
     AccountUsersList,
-    CampaignUnitcost,
-    CampaignDailybudget,
     CampaignChangeauditstampsLastmodified,
     CampaignChangeauditstampsCreated,
     CampaignChangeauditstamps,
-    CampaignRunschedule,
+    CampaignUnitcost,
+    CampaignDailybudget,
     CampaignVersion,
-    CampaignLocale,
+    CampaignRunschedule,
     CampaignTotalbudget,
+    CampaignLocale,
     Campaign,
     CampaignsListMetadata,
     CampaignsList,
-    CampaignGroupTotalbudget,
     CampaignGroupRunschedule,
-    CampaignGroupChangeauditstampsCreated,
+    CampaignGroupTotalbudget,
     CampaignGroupChangeauditstampsLastmodified,
+    CampaignGroupChangeauditstampsCreated,
     CampaignGroupChangeauditstamps,
     CampaignGroup,
     CampaignGroupsListMetadata,
@@ -153,22 +153,22 @@
     "AccountUser",
     "AccountUsersListMetadata",
     "AccountUsersList",
-    "CampaignUnitcost",
-    "CampaignDailybudget",
     "CampaignChangeauditstampsLastmodified",
     "CampaignChangeauditstampsCreated",
     "CampaignChangeauditstamps",
-    "CampaignRunschedule",
+    "CampaignUnitcost",
+    "CampaignDailybudget",
     "CampaignVersion",
-    "CampaignLocale",
+    "CampaignRunschedule",
     "CampaignTotalbudget",
+    "CampaignLocale",
     "Campaign",
     "CampaignsListMetadata",
     "CampaignsList",
-    "CampaignGroupTotalbudget",
     "CampaignGroupRunschedule",
-    "CampaignGroupChangeauditstampsCreated",
+    "CampaignGroupTotalbudget",
     "CampaignGroupChangeauditstampsLastmodified",
+    "CampaignGroupChangeauditstampsCreated",
     "CampaignGroupChangeauditstamps",
     "CampaignGroup",
     "CampaignGroupsListMetadata",

connectors/linkedin-ads/airbyte_agent_linkedin_ads/_vendored/connector_sdk/executor/local_executor.py

@@ -602,6 +602,88 @@ async def check(self) -> ExecutionResult:
                 error=str(e),
             )
 
+    async def check_entities(self, entities: list[str]) -> ExecutionResult:
+        """Perform health checks for specific entities by probing their list or get operations.
+
+        For each entity, looks up (entity_name, Action.LIST) in the operation index.
+        If not found, falls back to (entity_name, Action.GET). Runs all probes
+        concurrently and returns per-entity results.
+
+        Args:
+            entities: List of entity names to check.
+
+        Returns:
+            ExecutionResult with per-entity health check results.
+        """
+        logging.debug("check_entities: probing entities %s", entities)
+
+        standard_handler = next(
+            (h for h in self._operation_handlers if isinstance(h, _StandardOperationHandler)),
+            None,
+        )
+
+        if standard_handler is None:
+            entity_results = [
+                {"entity": name, "status": "skipped", "error": "No standard handler available", "checked_action": None}
+                for name in entities
+            ]
+            return ExecutionResult(
+                success=not entities,
+                data={"entity_results": entity_results, "status": "unhealthy" if entities else "healthy"},
+            )
+
+        tasks = [self._probe_entity(name, standard_handler) for name in entities]
+        entity_results = await asyncio.gather(*tasks)
+
+        all_healthy = all(r["status"] == "healthy" for r in entity_results)
+        failed = [r for r in entity_results if r["status"] != "healthy"]
+        error = None
+        if failed:
+            names = ", ".join(r["entity"] for r in failed)
+            error = f"Entity check failed for: {names}"
+        return ExecutionResult(
+            success=all_healthy,
+            data={
+                "entity_results": list(entity_results),
+                "status": "healthy" if all_healthy else "unhealthy",
+            },
+            error=error,
+        )
+
+    async def _probe_entity(self, entity_name: str, standard_handler: _StandardOperationHandler) -> dict[str, Any]:
+        """Probe a single entity's health by executing its list or get operation."""
+        endpoint = self._operation_index.get((entity_name, Action.LIST))
+        action = Action.LIST
+        if endpoint is None:
+            endpoint = self._operation_index.get((entity_name, Action.GET))
+            action = Action.GET
+        if endpoint is None:
+            return {
+                "entity": entity_name,
+                "status": "failed",
+                "error": f"Entity '{entity_name}' has no list or get operation available for checking",
+                "status_code": None,
+                "checked_action": None,
+            }
+        try:
+            params = {"limit": 1} if action == Action.LIST else {}
+            await standard_handler.execute_operation(entity_name, action, params)
+            return {
+                "entity": entity_name,
+                "status": "healthy",
+                "error": None,
+                "status_code": None,
+                "checked_action": action.value,
+            }
+        except Exception as e:
+            return {
+                "entity": entity_name,
+                "status": "unhealthy",
+                "error": str(e),
+                "status_code": getattr(e, "status_code", None),
+                "checked_action": action.value,
+            }
+
     async def _execute_operation(
         self,
         entity: str,

connectors/linkedin-ads/airbyte_agent_linkedin_ads/models.py

@@ -139,20 +139,6 @@ class AccountUsersList(BaseModel):
     elements: Union[list[AccountUser], Any] = Field(default=None)
     metadata: Union[AccountUsersListMetadata, Any] = Field(default=None)
 
-class CampaignUnitcost(BaseModel):
-    """Cost per unit (bid amount)"""
-    model_config = ConfigDict(extra="allow", populate_by_name=True)
-
-    amount: Union[str | None, Any] = Field(default=None)
-    currency_code: Union[str | None, Any] = Field(default=None, alias="currencyCode")
-
-class CampaignDailybudget(BaseModel):
-    """Daily budget configuration"""
-    model_config = ConfigDict(extra="allow", populate_by_name=True)
-
-    amount: Union[str | None, Any] = Field(default=None)
-    currency_code: Union[str | None, Any] = Field(default=None, alias="currencyCode")
-
 class CampaignChangeauditstampsLastmodified(BaseModel):
     """Nested schema for CampaignChangeauditstamps.lastModified"""
     model_config = ConfigDict(extra="allow", populate_by_name=True)
@@ -174,25 +160,32 @@ class CampaignChangeauditstamps(BaseModel):
     created: Union[CampaignChangeauditstampsCreated | None, Any] = Field(default=None)
     last_modified: Union[CampaignChangeauditstampsLastmodified | None, Any] = Field(default=None, alias="lastModified")
 
-class CampaignRunschedule(BaseModel):
-    """Campaign run schedule"""
+class CampaignUnitcost(BaseModel):
+    """Cost per unit (bid amount)"""
     model_config = ConfigDict(extra="allow", populate_by_name=True)
 
-    start: Union[int | None, Any] = Field(default=None)
-    end: Union[int | None, Any] = Field(default=None)
+    amount: Union[str | None, Any] = Field(default=None)
+    currency_code: Union[str | None, Any] = Field(default=None, alias="currencyCode")
+
+class CampaignDailybudget(BaseModel):
+    """Daily budget configuration"""
+    model_config = ConfigDict(extra="allow", populate_by_name=True)
+
+    amount: Union[str | None, Any] = Field(default=None)
+    currency_code: Union[str | None, Any] = Field(default=None, alias="currencyCode")
 
 class CampaignVersion(BaseModel):
     """Version information"""
     model_config = ConfigDict(extra="allow", populate_by_name=True)
 
     version_tag: Union[str | None, Any] = Field(default=None, alias="versionTag")
 
-class CampaignLocale(BaseModel):
-    """Campaign locale settings"""
+class CampaignRunschedule(BaseModel):
+    """Campaign run schedule"""
     model_config = ConfigDict(extra="allow", populate_by_name=True)
 
-    country: Union[str | None, Any] = Field(default=None)
-    language: Union[str | None, Any] = Field(default=None)
+    start: Union[int | None, Any] = Field(default=None)
+    end: Union[int | None, Any] = Field(default=None)
 
 class CampaignTotalbudget(BaseModel):
     """Total budget configuration"""
@@ -201,6 +194,13 @@ class CampaignTotalbudget(BaseModel):
     amount: Union[str | None, Any] = Field(default=None)
     currency_code: Union[str | None, Any] = Field(default=None, alias="currencyCode")
 
+class CampaignLocale(BaseModel):
+    """Campaign locale settings"""
+    model_config = ConfigDict(extra="allow", populate_by_name=True)
+
+    country: Union[str | None, Any] = Field(default=None)
+    language: Union[str | None, Any] = Field(default=None)
+
 class Campaign(BaseModel):
     """LinkedIn ad campaign object"""
     model_config = ConfigDict(extra="allow", populate_by_name=True)
@@ -248,26 +248,19 @@ class CampaignsList(BaseModel):
     elements: Union[list[Campaign], Any] = Field(default=None)
     metadata: Union[CampaignsListMetadata, Any] = Field(default=None)
 
-class CampaignGroupTotalbudget(BaseModel):
-    """Total budget for the campaign group"""
-    model_config = ConfigDict(extra="allow", populate_by_name=True)
-
-    amount: Union[str | None, Any] = Field(default=None)
-    currency_code: Union[str | None, Any] = Field(default=None, alias="currencyCode")
-
 class CampaignGroupRunschedule(BaseModel):
     """Campaign group run schedule"""
     model_config = ConfigDict(extra="allow", populate_by_name=True)
 
     start: Union[int | None, Any] = Field(default=None)
     end: Union[int | None, Any] = Field(default=None)
 
-class CampaignGroupChangeauditstampsCreated(BaseModel):
-    """Nested schema for CampaignGroupChangeauditstamps.created"""
+class CampaignGroupTotalbudget(BaseModel):
+    """Total budget for the campaign group"""
     model_config = ConfigDict(extra="allow", populate_by_name=True)
 
-    actor: Union[str | None, Any] = Field(default=None)
-    time: Union[int | None, Any] = Field(default=None)
+    amount: Union[str | None, Any] = Field(default=None)
+    currency_code: Union[str | None, Any] = Field(default=None, alias="currencyCode")
 
 class CampaignGroupChangeauditstampsLastmodified(BaseModel):
     """Nested schema for CampaignGroupChangeauditstamps.lastModified"""
@@ -276,6 +269,13 @@ class CampaignGroupChangeauditstampsLastmodified(BaseModel):
     actor: Union[str | None, Any] = Field(default=None)
     time: Union[int | None, Any] = Field(default=None)
 
+class CampaignGroupChangeauditstampsCreated(BaseModel):
+    """Nested schema for CampaignGroupChangeauditstamps.created"""
+    model_config = ConfigDict(extra="allow", populate_by_name=True)
+
+    actor: Union[str | None, Any] = Field(default=None)
+    time: Union[int | None, Any] = Field(default=None)
+
 class CampaignGroupChangeauditstamps(BaseModel):
     """Creation and last modification audit stamps"""
     model_config = ConfigDict(extra="allow", populate_by_name=True)

connectors/linkedin-ads/pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "airbyte-agent-linkedin-ads"
-version = "0.1.4"
+version = "0.1.5"
 description = "Airbyte Linkedin-Ads Connector for AI platforms"
 readme = "README.md"
 requires-python = ">=3.13"