Merge pull request #3226 from airbytehq/publish/klaviyo-v0.1.56

chore(klaviyo): bump to 0.1.56

Author: octavia-bot-hoard[bot]

connectors/klaviyo/CHANGELOG.md

@@ -1,5 +1,10 @@
 # Klaviyo changelog
 
+## [0.1.56] - 2026-04-09
+- Updated connector definition (YAML version 1.0.4)
+- Source commit: c5258deb
+- SDK version: 0.1.0
+
 ## [0.1.55] - 2026-04-09
 - Updated connector definition (YAML version 1.0.4)
 - Source commit: 6bf360a5

connectors/klaviyo/README.md

@@ -119,7 +119,7 @@ See the official [Klaviyo API reference](https://developers.klaviyo.com/en/refer
 
 ## Version information
 
-- **Package version:** 0.1.55
+- **Package version:** 0.1.56
 - **Connector version:** 1.0.4
-- **Generated with Connector SDK commit SHA:** 6bf360a546d577c9f76e8a6b8abf9ffc4dbfcf3a
+- **Generated with Connector SDK commit SHA:** c5258debd165ab701252c1436d4acfb475bf92b9
 - **Changelog:** [View changelog](https://github.com/airbytehq/airbyte-agent-connectors/blob/main/connectors/klaviyo/CHANGELOG.md)

connectors/klaviyo/airbyte_agent_klaviyo/__init__.py

@@ -13,13 +13,13 @@
     Profile,
     ProfilesListLinks,
     ProfilesList,
-    ListLinks,
     ListAttributes,
+    ListLinks,
     List,
     ListsListLinks,
     ListsList,
-    CampaignLinks,
     CampaignAttributes,
+    CampaignLinks,
     Campaign,
     CampaignsListLinks,
     CampaignsList,
@@ -126,13 +126,13 @@
     "Profile",
     "ProfilesListLinks",
     "ProfilesList",
-    "ListLinks",
     "ListAttributes",
+    "ListLinks",
     "List",
     "ListsListLinks",
     "ListsList",
-    "CampaignLinks",
     "CampaignAttributes",
+    "CampaignLinks",
     "Campaign",
     "CampaignsListLinks",
     "CampaignsList",

connectors/klaviyo/airbyte_agent_klaviyo/_vendored/connector_sdk/executor/local_executor.py

@@ -62,7 +62,36 @@
 
 
 class ParamResolutionError(Exception):
-    """Raised when a path parameter cannot be resolved for entity probing."""
+    """Raised when a path parameter cannot be resolved for entity probing.
+
+    Covers structural resolution failures (unresolvable param, self-reference,
+    parent with no LIST op, parent returning no records, missing parent key,
+    max recursion depth). ``_probe_entity`` converts these into UNHEALTHY
+    results so the backend controller classifies them as INCONCLUSIVE. SKIPPED
+    is reserved exclusively for "this entity has no list/get action at all".
+
+    Execution failures from probing a parent entity use ParentProbeError
+    instead, so the child can inherit the parent's ``status_code`` for
+    401/403 -> FAILED classification.
+    """
+
+
+class ParentProbeError(Exception):
+    """Raised when a parent entity's LIST probe fails during param resolution.
+
+    Wraps the original exception's message with parent-entity context for
+    debuggability, while preserving the parent's ``status_code`` so the child
+    can be classified the same way the parent would be (401/403 -> FAILED,
+    everything else -> INCONCLUSIVE at the backend controller layer).
+
+    Distinct from ``ParamResolutionError`` so the ``status_code`` survives --
+    both route through ``_probe_entity``'s UNHEALTHY branch, but only
+    ParentProbeError carries the parent's HTTP status.
+    """
+
+    def __init__(self, message: str, status_code: int | None = None) -> None:
+        super().__init__(message)
+        self.status_code = status_code
 
 
 class _OperationContext:
@@ -727,9 +756,7 @@ async def _probe_entity(
             # Also resolve query params that have a matching scoping or config
             # key, so explicit config values take precedence over defaults.
             for qp in endpoint.query_params:
-                if qp not in params_needing_resolution and (
-                    qp in self._scoping_index or qp in self.config_values
-                ):
+                if qp not in params_needing_resolution and (qp in self._scoping_index or qp in self.config_values):
                     params_needing_resolution.append(qp)
             if params_needing_resolution:
                 try:
@@ -744,7 +771,7 @@ async def _probe_entity(
                 except ParamResolutionError as exc:
                     return {
                         "entity": entity_name,
-                        "status": CHECK_STATUS_SKIPPED,
+                        "status": CHECK_STATUS_UNHEALTHY,
                         "error": str(exc),
                         "status_code": None,
                         "checked_action": action.value,
@@ -846,7 +873,10 @@ async def _resolve_path_params(
                         parent_params,
                     )
                 except Exception as exc:
-                    raise ParamResolutionError(f"Parent entity '{parent_entity_name}' probe failed: {exc}") from exc
+                    raise ParentProbeError(
+                        f"Parent entity '{parent_entity_name}' probe failed: {exc}",
+                        status_code=getattr(exc, "status_code", None),
+                    ) from exc
                 records = result.data if isinstance(result.data, list) else []
                 if not records:
                     raise ParamResolutionError(f"Parent entity '{parent_entity_name}' returned no records")

connectors/klaviyo/airbyte_agent_klaviyo/models.py

@@ -95,12 +95,6 @@ class ProfilesList(BaseModel):
     data: Union[list[Profile], Any] = Field(default=None)
     links: Union[ProfilesListLinks | None, Any] = Field(default=None)
 
-class ListLinks(BaseModel):
-    """Related links"""
-    model_config = ConfigDict(extra="allow", populate_by_name=True)
-
-    self: Union[str | None, Any] = Field(default=None)
-
 class ListAttributes(BaseModel):
     """List attributes"""
     model_config = ConfigDict(extra="allow", populate_by_name=True)
@@ -114,6 +108,12 @@ class ListAttributes(BaseModel):
     opt_in_process: Union[str | None, Any] = Field(default=None, description="Opt-in process type")
     """Opt-in process type"""
 
+class ListLinks(BaseModel):
+    """Related links"""
+    model_config = ConfigDict(extra="allow", populate_by_name=True)
+
+    self: Union[str | None, Any] = Field(default=None)
+
 class List(BaseModel):
     """A Klaviyo list for organizing profiles"""
     model_config = ConfigDict(extra="allow", populate_by_name=True)
@@ -138,12 +138,6 @@ class ListsList(BaseModel):
     data: Union[list[List], Any] = Field(default=None)
     links: Union[ListsListLinks | None, Any] = Field(default=None)
 
-class CampaignLinks(BaseModel):
-    """Related links"""
-    model_config = ConfigDict(extra="allow", populate_by_name=True)
-
-    self: Union[str | None, Any] = Field(default=None)
-
 class CampaignAttributes(BaseModel):
     """Campaign attributes"""
     model_config = ConfigDict(extra="allow", populate_by_name=True)
@@ -171,6 +165,12 @@ class CampaignAttributes(BaseModel):
     send_time: Union[str | None, Any] = Field(default=None, description="Actual send time")
     """Actual send time"""
 
+class CampaignLinks(BaseModel):
+    """Related links"""
+    model_config = ConfigDict(extra="allow", populate_by_name=True)
+
+    self: Union[str | None, Any] = Field(default=None)
+
 class Campaign(BaseModel):
     """A Klaviyo campaign"""
     model_config = ConfigDict(extra="allow", populate_by_name=True)

connectors/klaviyo/pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "airbyte-agent-klaviyo"
-version = "0.1.55"
+version = "0.1.56"
 description = "Airbyte Klaviyo Connector for AI platforms"
 readme = "README.md"
 requires-python = ">=3.13"