show

stream_kubejobs/__init__.py

@@ -182,17 +182,12 @@ class KubeJobStreamProgress(Plugin):
 
                 timestamp = time.time() * 1000
                 job_result_key = "job:results"
-                last_item_key = self.rds.lrange(job_result_key, -1, -1)
-                self.LOG.log("Last item key = " + str(last_item_key))
-                self.LOG.log("Collect period ="+str(self.collect_period))
-
+                last_item_key = self.rds.scard(job_result_key)
 
                 if (not last_item_key):
                     self.report_job(timestamp)
                     return
 
-
-
                 pipe = self.rds.pipeline()
                 pipe.llen('job')
                 pipe.llen('job:processing')
@@ -227,8 +222,7 @@ class KubeJobStreamProgress(Plugin):
                 self.LOG.log("Input Flux : %s" % input_flux)
                 self.LOG.log("Real output Flux : %s" % real_output_flux)
                 self.LOG.log("Expected output Flux : %s" % expected_output_flux)
-                self.LOG.log("Corrector term : %s" % int(self.corrector_term))
-                self.LOG.log("Error options : %s" % int(self.error_option))
+                self.LOG.log("Collect period ="+str(self.collect_period))
                 self.LOG.log("========================")
 
                 application_progress_error = \