shaliz-kong commited on
Commit ·
0ddcd64
1
Parent(s): 2fff85c
adde print inserted raws
Browse files- app/mapper.py +1 -0
app/mapper.py
CHANGED
|
@@ -472,6 +472,7 @@ def canonify_df(org_id: str, source_id: str, hours_window: int = 24) -> tuple[pd
|
|
| 472 |
)
|
| 473 |
rows_inserted = len(df_to_insert)
|
| 474 |
# In app/mapper.py, after `rows_inserted = len(df_to_insert)`
|
|
|
|
| 475 |
|
| 476 |
# ==================== DIAGNOSTIC QUERIES (DISABLE IN PROD) ====================
|
| 477 |
print(f"[canonify] 🔬 DIAGNOSTIC: Querying table immediately post-insert...")
|
|
|
|
| 472 |
)
|
| 473 |
rows_inserted = len(df_to_insert)
|
| 474 |
# In app/mapper.py, after `rows_inserted = len(df_to_insert)`
|
| 475 |
+
print(f"[canonify] 💾 Inserted {rows_inserted} rows into {table_name}")
|
| 476 |
|
| 477 |
# ==================== DIAGNOSTIC QUERIES (DISABLE IN PROD) ====================
|
| 478 |
print(f"[canonify] 🔬 DIAGNOSTIC: Querying table immediately post-insert...")
|