m

stream_kubejobs/__init__.py

@@ -325,7 +325,7 @@ class KubeJobStreamProgress(Plugin):
                  %s remaining attempts")
                          % (self.app_id, self.attempts))
             self.LOG.log(traceback.format_exc())
-            raise
+            raise ex
 
     def run(self):
         self.running = True
@@ -342,8 +342,8 @@ class KubeJobStreamProgress(Plugin):
             try:
                 time.sleep(self.collect_period)
                 self.monitoring_application()
-
             except Exception:
+                self.log("AAAAAAAAAAAAAAAAAA")
                 self.attempts -= 1
 
     def validate(self, data):