feat(cdk): add sentry_sdk.capture_message() to MemoryMonitor for high-memory warnings (AI-Triage PR)

airbyte_cdk/utils/memory_monitor.py

@@ -8,6 +8,8 @@
 from pathlib import Path
 from typing import Optional
 
+import sentry_sdk
+
 logger = logging.getLogger("airbyte")
 
 # cgroup v2 paths
@@ -47,6 +49,7 @@ def __init__(
         self._message_count = 0
         self._cgroup_version: Optional[int] = None
         self._probed = False
+        self._sentry_alerted = False
 
     def _probe_cgroup(self) -> None:
         """Detect which cgroup version (if any) is available.
@@ -132,9 +135,11 @@ def check_memory_usage(self) -> None:
         limit_gb = limit_bytes / (1024**3)
 
         if usage_ratio >= _MEMORY_THRESHOLD:
-            logger.warning(
-                "Source memory usage at %d%% of container limit (%.2f / %.2f GB).",
-                usage_percent,
-                usage_gb,
-                limit_gb,
+            message = (
+                "Source memory usage at %d%% of container limit (%.2f / %.2f GB)."
+                % (usage_percent, usage_gb, limit_gb)
             )
+            logger.warning(message)
+            if not self._sentry_alerted:
+                self._sentry_alerted = True
+                sentry_sdk.capture_message(message, level="warning")