diff --git a/cucyuqing/dbscan.py b/cucyuqing/dbscan.py index f782958..6398b4e 100644 --- a/cucyuqing/dbscan.py +++ b/cucyuqing/dbscan.py @@ -44,9 +44,9 @@ async def run_dbscan() -> DBScanResult: SELECT id, title, content, embedding FROM risk_news WHERE NOT embedding_updated_at IS NULL - AND time > now() - interval '14 day' + AND time > now() - interval '7 day' ORDER BY time desc - LIMIT 10000 + LIMIT 100000 ;""" ) rows = await cur.fetchall()