Update app/tasks/purge.py

app/tasks/purge.py

@@ -1,5 +1,9 @@
 from app.db import get_conn, ensure_raw_table
+from datetime import datetime, timedelta
+
 def purge_old_raw(org_id: str, hours=6):
     conn = get_conn(org_id)
-    conn.execute("DELETE FROM raw_rows WHERE ingested_at < now() - INTERVAL ? HOUR", [hours])
+    cutoff = datetime.now() - timedelta(hours=hours)
+    cutoff_str = cutoff.strftime("%Y-%m-%d %H:%M:%S")
+    conn.execute(f"DELETE FROM raw_rows WHERE ingested_at < TIMESTAMP '{cutoff_str}'")
     conn.commit(); conn.close()