diff --git a/server/api-service/lowcoder-server/src/main/java/org/lowcoder/runner/migrations/DatabaseChangelog.java b/server/api-service/lowcoder-server/src/main/java/org/lowcoder/runner/migrations/DatabaseChangelog.java
index e373ebc29..20611b8d8 100644
--- a/server/api-service/lowcoder-server/src/main/java/org/lowcoder/runner/migrations/DatabaseChangelog.java
+++ b/server/api-service/lowcoder-server/src/main/java/org/lowcoder/runner/migrations/DatabaseChangelog.java
@@ -359,7 +359,7 @@ public void addTimeSeriesSnapshotHistory(MongockTemplate mongoTemplate, CommonCo
             }
 
             // Delete the migrated records
-            Query deleteQuery = new Query(Criteria.where("createdAt").gte(thresholdDate));
+            Query deleteQuery = new Query(Criteria.where("createdAt").lte(thresholdDate));
             DeleteResult deleteResult = mongoTemplate.remove(deleteQuery, ApplicationHistorySnapshot.class);
 
             log.info("Deleted {} records from the source collection.", deleteResult.getDeletedCount());
@@ -390,7 +390,7 @@ public void addTimeSeriesSnapshotHistory(MongockTemplate mongoTemplate, CommonCo
                     .toCollection();
 
             // Delete the migrated records
-            Query deleteQuery = new Query(Criteria.where("createdAt").gte(thresholdDate));
+            Query deleteQuery = new Query(Criteria.where("createdAt").lte(thresholdDate));
             DeleteResult deleteResult = mongoTemplate.remove(deleteQuery, ApplicationHistorySnapshot.class);
 
             log.info("Deleted {} records from the source collection.", deleteResult.getDeletedCount());