diff --git a/apps/backend/subscription/tasks.py b/apps/backend/subscription/tasks.py
index 590bbf652..aafc62b5a 100644
--- a/apps/backend/subscription/tasks.py
+++ b/apps/backend/subscription/tasks.py
@@ -22,7 +22,7 @@
 
 from apps.backend.celery import app
 from apps.backend.components.collections.base import ActivityType
-from apps.backend.subscription import tools
+from apps.backend.subscription import handler, tools
 from apps.backend.subscription.constants import TASK_HOST_LIMIT
 from apps.backend.subscription.errors import SubscriptionInstanceEmpty
 from apps.backend.subscription.steps import StepFactory, agent
@@ -712,8 +712,10 @@ def run_subscription_task_and_create_instance(
         not_exist_instance_id = set(instance_not_in_scope) - set(deleted_instance_info)
         if not_exist_instance_id:
             records = list(
-                models.SubscriptionInstanceRecord.objects.filter(
-                    subscription_id=subscription.id, instance_id__in=not_exist_instance_id, is_latest=True
+                handler.SubscriptionTools.fetch_latest_record_ids_in_same_inst_id(
+                    models.SubscriptionInstanceRecord.objects.filter(
+                        subscription_id=subscription.id, instance_id__in=not_exist_instance_id
+                    )
                 )
             )
             for record in records: