Deploy Gapura AI update (exclude models; models pulled at runtime)

api/main.py

@@ -1559,11 +1559,13 @@ async def risk_summary(
                 "required_headers": [
                     "Report",
                     "Root_Caused",
+                    "Action_Taken",
                     "Irregularity_Complain_Category",
                     "Area",
                     "Airlines",
                     "Branch",
                     "HUB",
+                    "Status",
                 ],
                 "max_rows": max_rows_per_sheet,
             },
@@ -1572,11 +1574,13 @@ async def risk_summary(
                 "required_headers": [
                     "Report",
                     "Root_Caused",
+                    "Action_Taken",
                     "Irregularity_Complain_Category",
                     "Area",
                     "Airlines",
                     "Branch",
                     "HUB",
+                    "Status",
                 ],
                 "max_rows": max_rows_per_sheet,
             },
@@ -1594,6 +1598,31 @@ async def risk_summary(
             spreadsheet_id, "CGO", f"A1:Z{max_rows_per_sheet}", bypass_cache=bypass_cache
         )
 
+    if (len(non_cargo) + len(cargo)) == 0:
+        if fast:
+            data_map_retry = sheets_service.fetch_sheets_selected_columns(
+                spreadsheet_id, reqs, bypass_cache=True
+            )
+            non_cargo = data_map_retry.get("NON CARGO", [])
+            cargo = data_map_retry.get("CGO", [])
+            if (len(non_cargo) + len(cargo)) == 0:
+                sheet_ranges = [
+                    {"name": "NON CARGO", "range": f"A1:Z{max_rows_per_sheet}"},
+                    {"name": "CGO", "range": f"A1:Z{max_rows_per_sheet}"},
+                ]
+                data_map_wide = sheets_service.fetch_sheets_batch_data(
+                    spreadsheet_id, sheet_ranges, bypass_cache=True
+                )
+                non_cargo = data_map_wide.get("NON CARGO", [])
+                cargo = data_map_wide.get("CGO", [])
+        else:
+            non_cargo = sheets_service.fetch_sheet_data(
+                spreadsheet_id, "NON CARGO", f"A1:Z{max_rows_per_sheet}", bypass_cache=True
+            )
+            cargo = sheets_service.fetch_sheet_data(
+                spreadsheet_id, "CGO", f"A1:Z{max_rows_per_sheet}", bypass_cache=True
+            )
+
     for row in non_cargo:
         row["_source_sheet"] = "NON CARGO"
     for row in cargo:

data/risk_service.py

@@ -283,9 +283,9 @@ class RiskScoringService:
         if self._cached_summary:
             return self._cached_summary
 
-        airlines = self.risk_data.get("airlines", {})
-        branches = self.risk_data.get("branches", {})
-        hubs = self.risk_data.get("hubs", {})
+        airlines = self.risk_data.get("airlines", {}) or {}
+        branches = self.risk_data.get("branches", {}) or {}
+        hubs = self.risk_data.get("hubs", {}) or {}
 
         def get_risk_counts(data):
             counts = {"Critical": 0, "High": 0, "Medium": 0, "Low": 0}