diff --git a/deploy/profile-scripts/batch_reassess.py b/deploy/profile-scripts/batch_reassess.py
index 739e3313..b94ed8a2 100644
--- a/deploy/profile-scripts/batch_reassess.py
+++ b/deploy/profile-scripts/batch_reassess.py
@@ -191,7 +191,7 @@ def build_prompt(data):
     try:
         import sqlite3 as _sq, json as _j
         _db = _sq.connect("/home/hmo/MoFin/data/mofin.db")
-        _fr = _db.execute("SELECT cache_json FROM capital_flow_cache ORDER BY id DESC LIMIT 1").fetchone()
+        _fr = _db.execute("SELECT cache_json FROM capital_flow_cache WHERE id=1 ORDER BY updated_at DESC LIMIT 1").fetchone()
         if _fr and _fr[0]:
             _fc = _j.loads(_fr[0])
             _stocks = _fc.get("stocks", {})
diff --git a/deploy/profile-scripts/mofin_db.py b/deploy/profile-scripts/mofin_db.py
index effefd33..d1f6a186 100644
--- a/deploy/profile-scripts/mofin_db.py
+++ b/deploy/profile-scripts/mofin_db.py
@@ -2382,5 +2382,5 @@ def write_capital_flow_cache(conn, data: dict):
 
 def read_capital_flow_cache(conn) -> dict:
     import json
-    r = conn.execute("SELECT cache_json FROM capital_flow_cache ORDER BY id DESC LIMIT 1").fetchone()
+    r = conn.execute("SELECT cache_json FROM capital_flow_cache WHERE id=1 ORDER BY updated_at DESC LIMIT 1").fetchone()
     return json.loads(r['cache_json']) if r else {}