correcting errors

stream_kubejobs/__init__.py

@@ -152,8 +152,8 @@ 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)
-                self.LOG.log("COLLECT_PERIOD="+str(self.collect_period))
+                self.LOG.log("Last item key = " + str(last_item_key))
+                self.LOG.log("Collect period ="+str(self.collect_period))
 
 
                 if (not last_item_key):
@@ -189,7 +189,6 @@ class KubeJobStreamProgress(Plugin):
                 self.LOG.log("Tracked items : %s" % (tracked_items))
                 self.LOG.log("Input Flux : %s" % (input_lux))
                 self.LOG.log("Output Flux : %s" % (output_flux))
-
                 self.LOG.log("========================")
 
                 application_progress_error = \