Merge pull request #2615 from airbytehq/publish/google-drive-v0.1.90

chore(google-drive): bump to 0.1.90

Author: octavia-bot-hoard[bot]

connectors/google-drive/CHANGELOG.md

@@ -1,5 +1,10 @@
 # Google Drive changelog
 
+## [0.1.90] - 2026-03-23
+- Updated connector definition (YAML version 0.2.2)
+- Source commit: 6ad04bc3
+- SDK version: 0.1.0
+
 ## [0.1.89] - 2026-03-23
 - Updated connector definition (YAML version 0.2.2)
 - Source commit: 5718dee3

connectors/google-drive/README.md

@@ -129,7 +129,7 @@ See the official [Google-Drive API reference](https://developers.google.com/work
 
 ## Version information
 
-- **Package version:** 0.1.89
+- **Package version:** 0.1.90
 - **Connector version:** 0.2.2
-- **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/google-drive/CHANGELOG.md)

connectors/google-drive/airbyte_agent_google_drive/__init__.py

@@ -9,14 +9,14 @@
     GoogleDriveAuthConfig,
     GoogleDriveReplicationConfig,
     User,
-    FileVideomediametadata,
+    FileContentrestrictionsItem,
+    FileCapabilities,
+    FileShortcutdetails,
+    FileLinksharemetadata,
     FileImagemediametadataLocation,
     FileImagemediametadata,
-    FileLinksharemetadata,
-    FileShortcutdetails,
+    FileVideomediametadata,
     FileLabelinfo,
-    FileContentrestrictionsItem,
-    FileCapabilities,
     File,
     FilesListResponse,
     FileCreateParams,
@@ -27,12 +27,12 @@
     DriveCapabilities,
     Drive,
     DrivesListResponse,
-    PermissionPermissiondetailsItem,
     PermissionTeamdrivepermissiondetailsItem,
+    PermissionPermissiondetailsItem,
     Permission,
     PermissionsListResponse,
-    CommentQuotedfilecontent,
     Reply,
+    CommentQuotedfilecontent,
     Comment,
     CommentsListResponse,
     RepliesListResponse,
@@ -41,9 +41,9 @@
     Change,
     ChangesListResponse,
     StartPageToken,
-    AboutStoragequota,
     AboutDrivethemesItem,
     AboutTeamdrivethemesItem,
+    AboutStoragequota,
     About,
     FilesListResultMeta,
     DrivesListResultMeta,
@@ -94,14 +94,14 @@
     "GoogleDriveAuthConfig",
     "GoogleDriveReplicationConfig",
     "User",
-    "FileVideomediametadata",
+    "FileContentrestrictionsItem",
+    "FileCapabilities",
+    "FileShortcutdetails",
+    "FileLinksharemetadata",
     "FileImagemediametadataLocation",
     "FileImagemediametadata",
-    "FileLinksharemetadata",
-    "FileShortcutdetails",
+    "FileVideomediametadata",
     "FileLabelinfo",
-    "FileContentrestrictionsItem",
-    "FileCapabilities",
     "File",
     "FilesListResponse",
     "FileCreateParams",
@@ -112,12 +112,12 @@
     "DriveCapabilities",
     "Drive",
     "DrivesListResponse",
-    "PermissionPermissiondetailsItem",
     "PermissionTeamdrivepermissiondetailsItem",
+    "PermissionPermissiondetailsItem",
     "Permission",
     "PermissionsListResponse",
-    "CommentQuotedfilecontent",
     "Reply",
+    "CommentQuotedfilecontent",
     "Comment",
     "CommentsListResponse",
     "RepliesListResponse",
@@ -126,9 +126,9 @@
     "Change",
     "ChangesListResponse",
     "StartPageToken",
-    "AboutStoragequota",
     "AboutDrivethemesItem",
     "AboutTeamdrivethemesItem",
+    "AboutStoragequota",
     "About",
     "FilesListResultMeta",
     "DrivesListResultMeta",

connectors/google-drive/airbyte_agent_google_drive/_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,