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️⃣  zero-parameter timestamp filter
-    cutoff = datetime.utcnow() - timedelta(hours=hours_window)
-    cutoff_str = cutoff.strftime('%Y-%m-%d %H:%M:%S')
+    # 1️⃣  optional timestamp filter
+    cutoff_str = ""
+      if hours_window > 0:                       # allow 0 = disable filter
+        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
-      AND try_strptime(NULLIF(json_extract(row_data, '$.timestamp'), ''),
-                       '%Y-%m-%d %H:%M:%S')
-          >= TIMESTAMP '{cutoff_str}'
+      {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: