update config when necessary

Author: xutongNV

src/service/agent/helpers.py

@@ -264,20 +264,21 @@ def update_resource(backend: str, message: backend_messages.UpdateNodeBody,
         timestamp,
     )
 
-    postgres.execute_commit_command(commit_cmd, columns)
-    pool_config = connectors.fetch_verbose_pool_config(postgres, backend)
-    resource_entry = workflow.ResourcesEntry(hostname=message.hostname,
-                                             label_fields=message.label_fields,
-                                             backend=backend, taints=message.taints,
-                                             # Dummy placeholder values below
-                                             exposed_fields={},
-                                             usage_fields={},
-                                             non_workflow_usage_fields={},
-                                             allocatable_fields={},
-                                             pool_platform_labels={},
-                                             resource_type=connectors.BackendResourceType.SHARED,
-                                             conditions=message.conditions)
-    config_helpers.update_node_pool_platform(resource_entry, backend, pool_config)
+    rowcount = postgres.execute_commit_command(commit_cmd, columns)
+    if rowcount > 0:
+        pool_config = connectors.fetch_verbose_pool_config(postgres, backend)
+        resource_entry = workflow.ResourcesEntry(hostname=message.hostname,
+                                                 label_fields=message.label_fields,
+                                                 backend=backend, taints=message.taints,
+                                                 # Dummy placeholder values below
+                                                 exposed_fields={},
+                                                 usage_fields={},
+                                                 non_workflow_usage_fields={},
+                                                 allocatable_fields={},
+                                                 pool_platform_labels={},
+                                                 resource_type=connectors.BackendResourceType.SHARED,
+                                                 conditions=message.conditions)
+        config_helpers.update_node_pool_platform(resource_entry, backend, pool_config)
 
 
 def update_resource_usage(backend: str, message: backend_messages.UpdateNodeUsageBody,

src/utils/connectors/postgres.py

@@ -475,14 +475,17 @@ def execute_fetch_command(self, command: str,
                     cur.close()
 
     @retry
-    def execute_commit_command(self, command: str, args: Tuple):
+    def execute_commit_command(self, command: str, args: Tuple) -> int:
         """
         Connects and executes a command that updates the database.
 
         Args:
             command (str): The command to execute.
             args (Tuple): Any args for the command.
 
+        Returns:
+            int: The number of rows affected by the command.
+
         Raises:
             OSMODatabaseError: Error while executing the database command.
         """
@@ -491,8 +494,10 @@ def execute_commit_command(self, command: str, args: Tuple):
             try:
                 cur = conn.cursor()
                 cur.execute(command, args)
+                rowcount = cur.rowcount
                 cur.close()
                 conn.commit()
+                return rowcount
             except (psycopg2.DatabaseError, psycopg2.InterfaceError) as error:
                 try:
                     if cur is not None: