show

stream_kubejobs/__init__.py

@@ -316,9 +316,7 @@ class KubeJobStreamProgress(Plugin):
 
     def monitoring_application(self):
         try:
-
             self._publish_measurement()
-            return items_completed
         except Exception as ex:
             self.LOG.log(ex.message)
             self.LOG.log(("Error: No application found for %s.\
@@ -343,7 +341,6 @@ class KubeJobStreamProgress(Plugin):
                 time.sleep(self.collect_period)
                 self.monitoring_application()
             except Exception:
-                self.log("AAAAAAAAAAAAAAAAAA")
                 self.attempts -= 1
 
     def validate(self, data):