rafactor code for images

core/defect_detection_image.py

@@ -156,7 +156,7 @@ async def run_detection_group(
         return_exceptions=True
     )
 
-    # Bersihkan exception
+    # Bersihkan hasil dengan aman
     clean_results = []
     for r in results:
         if isinstance(r, Exception):
@@ -167,15 +167,19 @@ async def run_detection_group(
         else:
             clean_results.append(r)
 
+    # Tentukan status keseluruhan
     has_error = any(r.get("status") == "error" for r in clean_results)
     all_error = all(r.get("status") == "error" for r in clean_results)
 
-    status = "success"
-    message = "Success detecting defects"
     if all_error:
-        status, message = "error", "All cameras failed during detection"
+        status = "error"
+        message = "All cameras failed during detection"
     elif has_error:
-        status, message = "partial_error", "Some cameras failed during detection"
+        status = "partial_error"
+        message = "Some cameras failed during detection"
+    else:
+        status = "success"
+        message = "Success detecting defects"
 
     payload = {
         "status": status,
@@ -186,10 +190,12 @@ async def run_detection_group(
         "data": make_serializable(clean_results),
     }
 
+    # Kirim webhook
     try:
         async with httpx.AsyncClient(timeout=WEBHOOK_TIMEOUT) as client:
-            await client.post(webhook_url, json=payload)
-            logger.info(f"[DONE] Station {station_id}")
+            response = await client.post(webhook_url, json=payload)
+            response.raise_for_status()
+            logger.info(f"[DONE] Station {station_id} → webhook sent ({response.status_code})")
     except Exception as e:
         logger.exception(f"[ERROR] Webhook failed for Station {station_id}: {e}")