Create ingest/health.py

ingest/health.py

@@ -1,17 +1,10 @@
-import time
+from .registry import get_all_adapters
 
-def check_health(adapter):
-    start = time.time()
-    try:
-        latency_ms = int((time.time() - start) * 1000)
-        return {
-            "source": adapter.source_name,
-            "status": "healthy",
-            "latency_ms": latency_ms
+def get_adapter_health():
+    health = {}
+    for adapter in get_all_adapters():
+        health[adapter.name] = {
+            "live": adapter.is_live,
+            "extended": adapter.is_extended,
         }
-    except Exception:
-        return {
-            "source": adapter.source_name,
-            "status": "unhealthy",
-            "latency_ms": None
-        }
+    return health