cleaned returned for json

app/mapper.py

@@ -483,7 +483,8 @@ def canonify_df(org_id: str, source_id: str, hours_window: int = 24) -> tuple[pd
                     print(f"[canonify] ✅ Schema v{version_id} marked as applied")
                 except Exception as e:
                     print(f"[canonify] ⚠️ Schema update warning (non-critical): {e}")
-
+     # At the very end of canonify_df function, line ~470
+    df = df.replace([np.inf, -np.inf, np.nan], None)  # Clean for JSON response
     duration_ms = (datetime.now() - start_time).total_seconds() * 1000
     print(f"[canonify] ✅ Pipeline complete in {duration_ms:.2f}ms for {org_id}")