diff --git a/backend/services/analysis.py b/backend/services/analysis.py
index 1956a42..790ee4f 100644
--- a/backend/services/analysis.py
+++ b/backend/services/analysis.py
@@ -670,10 +670,10 @@ def refill_backlog(max_users=3, max_daily=100, max_activity=100):
                 "WHERE a.user_id = ? AND a.id IS NOT NULL "
                 "AND NOT EXISTS (SELECT 1 FROM ai_insights ai "
                 "  WHERE ai.user_id = a.user_id AND ai.kind = 'activity' "
-                "  AND ai.subject = CAST(a.id AS TEXT)) "
+                "  AND ai.subject = a.id) "
                 "AND NOT EXISTS (SELECT 1 FROM ai_jobs aj "
                 "  WHERE aj.user_id = a.user_id AND aj.kind = 'activity' "
-                "  AND aj.subject = CAST(a.id AS TEXT)) "
+                "  AND aj.subject = a.id) "
                 "ORDER BY a.start_time DESC LIMIT ?",
                 [uid, max_activity],
             )