Update app/mapper.py

app/mapper.py

@@ -95,18 +95,18 @@ def canonify_df(org_id: str, hours_window: int = 24) -> pd.DataFrame:
     conn = get_conn(org_id)
     ensure_raw_table(conn)
 
-    # 1️⃣  optional timestamp filter
+    # 1️⃣  optional timestamp filter (zero ? params)
     cutoff_str = ""
-      if hours_window > 0:                       # allow 0 = disable filter
+    if hours_window > 0:
         cutoff = datetime.utcnow() - timedelta(hours=hours_window)
         cutoff_str = cutoff.strftime('%Y-%m-%d %H:%M:%S')
 
     rows = sql(conn, f"""
-    SELECT row_data
-    FROM raw_rows
-    WHERE row_data IS NOT NULL
-      AND LENGTH(row_data) > 0
-      {f"AND try_strptime(NULLIF(json_extract(row_data, '$.timestamp'), ''), '%Y-%m-%d %H:%M:%S') >= TIMESTAMP '{cutoff_str}'" if hours_window > 0 else ""}
+        SELECT row_data
+        FROM raw_rows
+        WHERE row_data IS NOT NULL
+          AND LENGTH(row_data) > 0
+          {f"AND try_strptime(NULLIF(json_extract(row_data, '$.timestamp'), ''), '%Y-%m-%d %H:%M:%S') >= TIMESTAMP '{cutoff_str}'" if hours_window > 0 else ""}
     """)
 
     if not rows: