fix: 修复未写入db_module_id TencentBlueKing#7186

zfrendo · Sep 30, 2024 · 0e0ab55 · 0e0ab55
1 parent cbf5ee7
commit 0e0ab55
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/dbm-ui/backend/db_meta/api/cluster/tendbcluster/remotedb_node_migrate.py b/dbm-ui/backend/db_meta/api/cluster/tendbcluster/remotedb_node_migrate.py
@@ -89,8 +89,8 @@ def storage_create(
                 )
 
         api.machine.create(machines=machines, creator=creator, bk_cloud_id=bk_cloud_id)
-        machine_objects = Machine.objects.filter(bk_cloud_id=bk_cloud_id, ip__in=[machine_ips])
-        machine_objects.update(db_module_id=cluster.db_module_id)
+        machine_objs = Machine.objects.filter(bk_cloud_id=bk_cloud_id, ip__in=machine_ips)
+        machine_objs.update(db_module_id=cluster.db_module_id)
         api.storage_instance.create(
             instances=storages, creator=creator, time_zone=time_zone, status=InstanceStatus.RESTORING
         )

diff --git a/dbm-ui/backend/flow/utils/mysql/mysql_db_meta.py b/dbm-ui/backend/flow/utils/mysql/mysql_db_meta.py
@@ -728,10 +728,10 @@ def slave_recover_add_instance(self):
                 bk_cloud_id=int(self.ticket_data["bk_cloud_id"]),
                 creator=self.ticket_data["created_by"],
             )
-            machines = Machine.objects.filter(
+            machine_objs = Machine.objects.filter(
                 bk_cloud_id=self.ticket_data["bk_cloud_id"], ip=self.cluster["install_ip"]
             )
-            machines.update(db_module_id=self.ticket_data["db_module_id"])
+            machine_objs.update(db_module_id=self.ticket_data["db_module_id"])
             storage_objs = api.storage_instance.create(
                 instances=storage_instances,
                 creator=self.ticket_data["created_by"],
@@ -850,11 +850,11 @@ def migrate_cluster_add_instance(self):
             api.machine.create(
                 bk_cloud_id=self.ticket_data["bk_cloud_id"], machines=machines, creator=self.ticket_data["created_by"]
             )
-            machines = Machine.objects.filter(
+            machines_objs = Machine.objects.filter(
                 bk_cloud_id=self.ticket_data["bk_cloud_id"],
                 ip__in=[self.cluster["new_slave_ip"], self.cluster["new_master_ip"]],
             )
-            machines.update(db_module_id=self.ticket_data["db_module_id"])
+            machines_objs.update(db_module_id=self.ticket_data["db_module_id"])
             storage_objs = api.storage_instance.create(
                 instances=storage_instances,
                 creator=self.ticket_data["created_by"],