Update services/report_data_handler.py

services/report_data_handler.py

@@ -240,6 +240,17 @@ def save_actionable_okrs(org_urn: str, actionable_okrs: Dict[str, Any], report_i
     
     try:
         objectives_data = actionable_okrs.get("okrs", [])
+
+        # Defensive check: If data is a string, try to parse it as JSON.
+        if isinstance(objectives_data, str):
+            logger.warning("The 'okrs' data is a string. Attempting to parse as JSON.")
+            try:
+                objectives_data = json.loads(objectives_data)
+                logger.info("Successfully parsed 'okrs' data from JSON string.")
+            except json.JSONDecodeError:
+                logger.error("Failed to parse 'okrs' data. The string is not valid JSON.", exc_info=True)
+                return # Abort if data is malformed
+
         if not objectives_data:
             logger.warning(f"No OKRs found in the input for org_urn: {org_urn}. Aborting save process.")
             return
@@ -272,4 +283,3 @@ def save_actionable_okrs(org_urn: str, actionable_okrs: Dict[str, Any], report_i
         
     except Exception as e:
         logger.exception(f"An unhandled exception occurred during the save_actionable_okrs orchestration for org_urn {org_urn}: {e}")
-