Merge pull request #2596 from airbytehq/publish/confluence-v0.1.4

chore(confluence): bump to 0.1.4

Author: octavia-bot-hoard[bot]

connectors/confluence/CHANGELOG.md

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

connectors/confluence/README.md

@@ -113,7 +113,7 @@ See the official [Confluence API reference](https://developer.atlassian.com/clou
 
 ## Version information
 
-- **Package version:** 0.1.3
+- **Package version:** 0.1.4
 - **Connector version:** 1.0.0
-- **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/confluence/CHANGELOG.md)

connectors/confluence/airbyte_agent_confluence/__init__.py

@@ -11,15 +11,15 @@
     Space,
     SpacesListLinks,
     SpacesList,
+    PageBody,
     PageLinks,
     PageVersion,
-    PageBody,
     Page,
     PagesListLinks,
     PagesList,
-    BlogPostVersion,
-    BlogPostBody,
     BlogPostLinks,
+    BlogPostBody,
+    BlogPostVersion,
     BlogPost,
     BlogPostsListLinks,
     BlogPostsList,
@@ -28,8 +28,8 @@
     GroupsListLinks,
     GroupsList,
     AuditRecordAffectedobject,
-    AuditRecordAssociatedobjectsItem,
     AuditRecordAuthor,
+    AuditRecordAssociatedobjectsItem,
     AuditRecord,
     AuditRecordsListLinks,
     AuditRecordsList,
@@ -96,15 +96,15 @@
     "Space",
     "SpacesListLinks",
     "SpacesList",
+    "PageBody",
     "PageLinks",
     "PageVersion",
-    "PageBody",
     "Page",
     "PagesListLinks",
     "PagesList",
-    "BlogPostVersion",
-    "BlogPostBody",
     "BlogPostLinks",
+    "BlogPostBody",
+    "BlogPostVersion",
     "BlogPost",
     "BlogPostsListLinks",
     "BlogPostsList",
@@ -113,8 +113,8 @@
     "GroupsListLinks",
     "GroupsList",
     "AuditRecordAffectedobject",
-    "AuditRecordAssociatedobjectsItem",
     "AuditRecordAuthor",
+    "AuditRecordAssociatedobjectsItem",
     "AuditRecord",
     "AuditRecordsListLinks",
     "AuditRecordsList",

connectors/confluence/airbyte_agent_confluence/_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/confluence/airbyte_agent_confluence/models.py

@@ -67,6 +67,15 @@ class SpacesList(BaseModel):
     results: Union[list[Space], Any] = Field(default=None)
     links: Union[SpacesListLinks, Any] = Field(default=None, alias="_links")
 
+class PageBody(BaseModel):
+    """Page body content"""
+    model_config = ConfigDict(extra="allow", populate_by_name=True)
+
+    storage: Union[dict[str, Any], Any] = Field(default=None, description="Storage format body")
+    """Storage format body"""
+    atlas_doc_format: Union[dict[str, Any], Any] = Field(default=None, description="Atlas doc format body")
+    """Atlas doc format body"""
+
 class PageLinks(BaseModel):
     """Links related to the page"""
     model_config = ConfigDict(extra="allow", populate_by_name=True)
@@ -99,15 +108,6 @@ class PageVersion(BaseModel):
     ncs_step_version: Union[Any, Any] = Field(default=None, alias="ncsStepVersion", description="NCS step version")
     """NCS step version"""
 
-class PageBody(BaseModel):
-    """Page body content"""
-    model_config = ConfigDict(extra="allow", populate_by_name=True)
-
-    storage: Union[dict[str, Any], Any] = Field(default=None, description="Storage format body")
-    """Storage format body"""
-    atlas_doc_format: Union[dict[str, Any], Any] = Field(default=None, description="Atlas doc format body")
-    """Atlas doc format body"""
-
 class Page(BaseModel):
     """Confluence page object"""
     model_config = ConfigDict(extra="allow", populate_by_name=True)
@@ -143,6 +143,30 @@ class PagesList(BaseModel):
     results: Union[list[Page], Any] = Field(default=None)
     links: Union[PagesListLinks, Any] = Field(default=None, alias="_links")
 
+class BlogPostLinks(BaseModel):
+    """Links related to the blog post"""
+    model_config = ConfigDict(extra="allow", populate_by_name=True)
+
+    webui: Union[str, Any] = Field(default=None, description="Web UI link")
+    """Web UI link"""
+    editui: Union[str, Any] = Field(default=None, description="Edit UI link")
+    """Edit UI link"""
+    edituiv2: Union[str, Any] = Field(default=None, description="Edit UI v2 link")
+    """Edit UI v2 link"""
+    tinyui: Union[str, Any] = Field(default=None, description="Tiny UI link")
+    """Tiny UI link"""
+    base: Union[str, Any] = Field(default=None, description="Base URL")
+    """Base URL"""
+
+class BlogPostBody(BaseModel):
+    """Blog post body content"""
+    model_config = ConfigDict(extra="allow", populate_by_name=True)
+
+    storage: Union[dict[str, Any], Any] = Field(default=None, description="Storage format body")
+    """Storage format body"""
+    atlas_doc_format: Union[dict[str, Any], Any] = Field(default=None, description="Atlas doc format body")
+    """Atlas doc format body"""
+
 class BlogPostVersion(BaseModel):
     """Version information"""
     model_config = ConfigDict(extra="allow", populate_by_name=True)
@@ -160,30 +184,6 @@ class BlogPostVersion(BaseModel):
     ncs_step_version: Union[Any, Any] = Field(default=None, alias="ncsStepVersion", description="NCS step version")
     """NCS step version"""
 
-class BlogPostBody(BaseModel):
-    """Blog post body content"""
-    model_config = ConfigDict(extra="allow", populate_by_name=True)
-
-    storage: Union[dict[str, Any], Any] = Field(default=None, description="Storage format body")
-    """Storage format body"""
-    atlas_doc_format: Union[dict[str, Any], Any] = Field(default=None, description="Atlas doc format body")
-    """Atlas doc format body"""
-
-class BlogPostLinks(BaseModel):
-    """Links related to the blog post"""
-    model_config = ConfigDict(extra="allow", populate_by_name=True)
-
-    webui: Union[str, Any] = Field(default=None, description="Web UI link")
-    """Web UI link"""
-    editui: Union[str, Any] = Field(default=None, description="Edit UI link")
-    """Edit UI link"""
-    edituiv2: Union[str, Any] = Field(default=None, description="Edit UI v2 link")
-    """Edit UI v2 link"""
-    tinyui: Union[str, Any] = Field(default=None, description="Tiny UI link")
-    """Tiny UI link"""
-    base: Union[str, Any] = Field(default=None, description="Base URL")
-    """Base URL"""
-
 class BlogPost(BaseModel):
     """Confluence blog post object"""
     model_config = ConfigDict(extra="allow", populate_by_name=True)
@@ -261,15 +261,6 @@ class AuditRecordAffectedobject(BaseModel):
     object_type: Union[str, Any] = Field(default=None, alias="objectType", description="Type of the affected object")
     """Type of the affected object"""
 
-class AuditRecordAssociatedobjectsItem(BaseModel):
-    """Nested schema for AuditRecord.associatedObjects_item"""
-    model_config = ConfigDict(extra="allow", populate_by_name=True)
-
-    name: Union[str, Any] = Field(default=None, description="Name of the associated object")
-    """Name of the associated object"""
-    object_type: Union[str, Any] = Field(default=None, alias="objectType", description="Type of the associated object")
-    """Type of the associated object"""
-
 class AuditRecordAuthor(BaseModel):
     """User who triggered the audit event"""
     model_config = ConfigDict(extra="allow", populate_by_name=True)
@@ -289,6 +280,15 @@ class AuditRecordAuthor(BaseModel):
     operations: Union[Any, Any] = Field(default=None, description="Operations available for the author")
     """Operations available for the author"""
 
+class AuditRecordAssociatedobjectsItem(BaseModel):
+    """Nested schema for AuditRecord.associatedObjects_item"""
+    model_config = ConfigDict(extra="allow", populate_by_name=True)
+
+    name: Union[str, Any] = Field(default=None, description="Name of the associated object")
+    """Name of the associated object"""
+    object_type: Union[str, Any] = Field(default=None, alias="objectType", description="Type of the associated object")
+    """Type of the associated object"""
+
 class AuditRecord(BaseModel):
     """Confluence audit record"""
     model_config = ConfigDict(extra="allow", populate_by_name=True)

connectors/confluence/pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "airbyte-agent-confluence"
-version = "0.1.3"
+version = "0.1.4"
 description = "Airbyte Confluence Connector for AI platforms"
 readme = "README.md"
 requires-python = ">=3.13"