Update services/report_data_handler.py

services/report_data_handler.py

@@ -109,15 +109,16 @@ def save_objectives(
         return []
 
     try:
-        payloads = [
-            {
+        payloads = []
+        for obj in objectives_data:
+            timeline = obj.get("objective_timeline")
+            payloads.append({
                 "description": obj.get("objective_description"),
-                "timeline": obj.get("objective_timeline"),
+                # FIX: Convert Enum to its value before sending.
+                "timeline": timeline.value if hasattr(timeline, 'value') else timeline,
                 "owner": obj.get("objective_owner"),
                 "report": report_id,
-            }
-            for obj in objectives_data
-        ]
+            })
 
         logger.info(f"Attempting to save {payloads} objectives for report_id: {report_id}")
         response_data = bulk_upload_to_bubble(payloads, BUBBLE_OKR_TABLE_NAME)
@@ -173,13 +174,15 @@ def save_key_results(
                  continue # Skip this loop iteration
 
             for kr in objective_data.get("key_results", []):
+                kr_type = kr.get("key_result_type")
                 key_results_to_process.append(kr)
                 key_result_payloads.append({
                     "okr": parent_objective_id,
                     "description": kr.get("key_result_description"),
                     "target_metric": kr.get("target_metric"),
                     "target_value": kr.get("target_value"),
-                    "kr_type": kr.get("key_result_type"),
+                    # FIX: Convert Enum to its value before sending.
+                    "kr_type": kr_type.value if hasattr(kr_type, 'value') else kr_type,
                     "data_subject": kr.get("data_subject"),
                 })
 
@@ -231,21 +234,26 @@ def save_tasks(
         task_payloads = []
         for key_result_data, parent_key_result_id in key_results_with_ids:
             for task in key_result_data.get("tasks", []):
+                priority = task.get("priority")
+                effort = task.get("effort")
+                timeline = task.get("timeline")
                 task_payloads.append({
                     "key_result": parent_key_result_id,
                     "description": task.get("task_description"),
                     "objective_deliverable": task.get("objective_deliverable"),
                     "category": task.get("task_category"),
-                    "priority": task.get("priority"),
+                    # FIX: Convert Enum to its value before sending.
+                    "priority": priority.value if hasattr(priority, 'value') else priority,
                     "priority_justification": task.get("priority_justification"),
-                    "effort": task.get("effort"),
-                    "timeline": task.get("timeline"),
+                    "effort": effort.value if hasattr(effort, 'value') else effort,
+                    "timeline": timeline.value if hasattr(timeline, 'value') else timeline,
                     "responsible_party": task.get("responsible_party"),
                     "success_criteria_metrics": task.get("success_criteria_metrics"),
                     "dependencies": task.get("dependencies_prerequisites"),
                     "why": task.get("why_proposed"),
                 })
 
+
         if not task_payloads:
             logger.info("No tasks to save.")
             return []