From: Radosław Korzeniewski <radoslaw@korzeniewski.net>
Date: Thu, 16 Dec 2021 14:37:14 +0000 (+0100)
Subject: kubernetes: Update k8s agent count handling. Fix #7569
X-Git-Tag: Beta-15.0.0~706
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=14a79278c8eea5b11acfe9521588ddc19799332a;p=thirdparty%2Fbacula.git

kubernetes: Update k8s agent count handling. Fix #7569
---

diff --git a/bacula/src/plugins/fd/kubernetes-backend/baculak8s/jobs/backup_job.py b/bacula/src/plugins/fd/kubernetes-backend/baculak8s/jobs/backup_job.py
index b9988255f..35ed43a13 100644
--- a/bacula/src/plugins/fd/kubernetes-backend/baculak8s/jobs/backup_job.py
+++ b/bacula/src/plugins/fd/kubernetes-backend/baculak8s/jobs/backup_job.py
@@ -74,25 +74,26 @@ class BackupJob(EstimationJob):
             count: Number of POD
         """
         logging.debug("PO_PODS: {}".format(self._plugin.pods_counter))
-        po_pods = PluginObject("/{}/".format(defaultk8spath),
-                               "Kubernetes PODs",
-                               cat="Container",
-                               potype="POD",
-                               src=self._plugin.po_source_data,
-                               uuid=self._plugin.po_source_data,
-                               count=self._plugin.pods_counter)
-        self._io.send_plugin_object(po_pods)
+        if self._plugin.pods_counter > 0:
+            po_pods = PluginObject("/{}/".format(defaultk8spath),
+                                "Kubernetes PODs",
+                                cat="Container",
+                                potype="POD",
+                                src=self._plugin.po_source_data,
+                                uuid=self._plugin.po_source_data,
+                                count=self._plugin.pods_counter)
+            self._io.send_plugin_object(po_pods)
         logging.debug("PO_PVCS: {} {}".format(self._plugin.pvcs_counter, self._plugin.pvcs_totalsize))
-        po_pvcs = PluginObject("/{}/".format(defaultk8spath),
-                               "Kubernetes Persistent Volume Claims",
-                               cat="Container",
-                               potype="PVC",
-                               src=self._plugin.po_source_data,
-                               uuid=self._plugin.po_source_data,
-                               count=self._plugin.pvcs_counter,
-                               size=self._plugin.pvcs_totalsize)
-        logging.debug("PO_PVCS: {}".format(po_pvcs))
-        self._io.send_plugin_object(po_pvcs)
+        if self._plugin.pvcs_counter > 0:
+            po_pvcs = PluginObject("/{}/".format(defaultk8spath),
+                                "Kubernetes Persistent Volume Claims",
+                                cat="Container",
+                                potype="PVC",
+                                src=self._plugin.po_source_data,
+                                uuid=self._plugin.po_source_data,
+                                count=self._plugin.pvcs_counter,
+                                size=self._plugin.pvcs_totalsize)
+            self._io.send_plugin_object(po_pvcs)
 
     def _backup_file(self, data):
         file_info = data.get('fi')