Update app/mapper.py

app/mapper.py

@@ -100,10 +100,12 @@ def canonify_df(org_id: str, hours_window: int = 24) -> pd.DataFrame:
     cutoff_str = cutoff.strftime('%Y-%m-%d %H:%M:%S')
 
     rows = sql(conn, f"""
-        SELECT row_data
-        FROM raw_rows
-        WHERE try_strptime(NULLIF(json_extract(row_data, '$.timestamp'), ''),
-                           '%Y-%m-%d %H:%M:%S')
+    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}'
     """)