Don't process pods that have no package name label

spack · Dec 8, 2023 · d2f4caa · d2f4caa
1 parent 7ba060a
commit d2f4caa
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/analytics/analytics/management/commands/collect_running_jobs.py b/analytics/analytics/management/commands/collect_running_jobs.py
@@ -140,6 +140,12 @@ def handle_scheduled_pipeline_pod(wrapped_event: dict, start_time: datetime):
         logger.warning(f'Could not retrieve pod {pod_name} in namespace "pipeline"')
         return
 
+    # Ensure that this pod has a non-empty package name label before continuing
+    labels: dict = pod.to_dict()["metadata"]["labels"]
+    if labels.get("metrics/spack_job_spec_pkg_name", "") == "":
+        logger.debug(f"Skipping pod with missing package name: {pod_name}")
+        return
+
     # Retrieve node
     node_name = pod.to_dict()["spec"]["node_name"]
     node = client.read_node(name=node_name).to_dict()  # type: ignore