inserted raws verification

app/mapper.py

@@ -456,7 +456,7 @@ def canonify_df(org_id: str, source_id: str, hours_window: int = 24) -> tuple[pd
         # Insert data
         if not df.empty:
             table_info = duck.execute(f"PRAGMA table_info('{table_name}')").fetchall()
-            table_cols = [str(r[0]) for r in table_info]
+            table_cols = [str(r[1]) for r in table_info]
             
             df_to_insert = df[[col for col in df.columns if col in table_cols]]
             
@@ -471,7 +471,28 @@ def canonify_df(org_id: str, source_id: str, hours_window: int = 24) -> tuple[pd
                     df_to_insert.values.tolist()
                 )
                 rows_inserted = len(df_to_insert)
-                print(f"[canonify] 💾 Inserted {rows_inserted} rows into {table_name}")
+                # In app/mapper.py, after `rows_inserted = len(df_to_insert)`
+
+                # ==================== DIAGNOSTIC QUERIES (DISABLE IN PROD) ====================
+                print(f"[canonify] 🔬 DIAGNOSTIC: Querying table immediately post-insert...")
+                try:
+                    diagnostic_conn = get_conn(org_id)
+    
+                    # Check total row count
+                    total_rows = diagnostic_conn.execute(f"SELECT COUNT(*) FROM {table_name}").fetchone()[0]
+                    print(f"[canonify] 🔬 DIAGNOSTIC: Table {table_name} has {total_rows} total rows")
+    
+                    # Sample the data
+                    sample = diagnostic_conn.execute(f"SELECT * FROM {table_name} LIMIT 3").df()
+                    if not sample.empty:
+                        print(f"[canonify] 🔬 DIAGNOSTIC: Sample data:\n{sample.to_string()}")
+                    else:
+                        print(f"[canonify] 🔬 DIAGNOSTIC: Table exists but SELECT returned ZERO rows")
+    
+                        diagnostic_conn.close()
+                except Exception as diag_e:
+                    print(f"[canonify] 🔬 DIAGNOSTIC ERROR: {diag_e}")
+# ============================================================================
             
             # Mark schema as applied
             if is_new_schema and version_id: