Fix the DAG related to Node Pool Status. (GoogleCloudPlatform#1053)

This change fixes the following main file:
- dags/tpu_observability/utils/node_pool_util.py

Affected DAGs:
- dags/tpu_observability/multi_host_nodepool_rollback_dag.py
- dags/tpu_observability/node_pool_status.py
- dags/tpu_observability/update_node_pool_label.py

Author: yuna-tzeng

dags/tpu_observability/multi_host_nodepool_rollback_dag.py

@@ -59,7 +59,7 @@
             "CLUSTER_NAME", default_var="tpu-observability-automation"
         ),
         node_pool_name=Variable.get(
-            "NODE_POOL_NAME", default_var="multi_host_nodepool_rollback_auto"
+            "NODE_POOL_NAME", default_var="multi-host-nodepool-rollback-auto"
         ),
         location=Variable.get("LOCATION", default_var=Region.US_CENTRAL1.value),
         node_locations=Variable.get(

dags/tpu_observability/utils/node_pool_util.py

@@ -232,12 +232,12 @@ def _query_status_metric(node_pool: Info) -> Status:
   start_time = TimeUtil.from_datetime(start_time_datetime)
   end_time = TimeUtil.from_datetime(now)
 
-  filter_string = (
-      'metric.type="kubernetes.io/node_pool/status" '
-      f'resource.labels.project_id = "{node_pool.project_id}" '
-      f'resource.labels.cluster_name = "{node_pool.cluster_name}" '
-      f'resource.labels.node_pool_name = "{node_pool.node_pool_name}"'
-  )
+  filter_string = [
+      'metric.type="kubernetes.io/node_pool/status"',
+      f'resource.labels.project_id = "{node_pool.project_id}"',
+      f'resource.labels.cluster_name = "{node_pool.cluster_name}"',
+      f'resource.labels.node_pool_name = "{node_pool.node_pool_name}"',
+  ]
 
   # A single query to the Monitoring API can return multiple TimeSeries objects,
   # especially if the 'status' label changed within the time window (e.g., from
@@ -355,12 +355,12 @@ def wait_for_availability(
   start_time = TimeUtil.from_datetime(start_time_datetime)
   end_time = TimeUtil.from_datetime(now)
 
-  filter_string = (
-      'metric.type="kubernetes.io/node_pool/multi_host/available" '
-      f'resource.labels.project_id = "{node_pool.project_id}" '
-      f'resource.labels.cluster_name="{node_pool.cluster_name}" '
-      f'resource.labels.node_pool_name="{node_pool.node_pool_name}"'
-  )
+  filter_string = [
+      'metric.type="kubernetes.io/node_pool/multi_host/available"',
+      f'resource.labels.project_id = "{node_pool.project_id}"',
+      f'resource.labels.cluster_name="{node_pool.cluster_name}"',
+      f'resource.labels.node_pool_name="{node_pool.node_pool_name}"',
+  ]
 
   page_result = query_time_series(
       project_id=node_pool.project_id,