Commit 8d2a7bd2 authored by Ignacio's avatar Ignacio
Browse files

minor erros

parent 9c7969f5
...@@ -167,7 +167,9 @@ class KubeJobStreamProgress(Plugin): ...@@ -167,7 +167,9 @@ class KubeJobStreamProgress(Plugin):
num_processing_jobs = min(num_processing_jobs, replicas) num_processing_jobs = min(num_processing_jobs, replicas)
tracked_items = num_processing_jobs + items_completed tracked_items = num_processing_jobs + items_completed
tracked_items += main_q_size tracked_items += main_q_size
flux = (tracked_items - self.tracked_items)/self.collect_period input_flux = (tracked_items - self.last_tracked_items)/self.collect_period
output_flux = (items_completed - self.last_completed_items)/self.collect_period
error = self.get_error(tracked_items, items_completed, main_q_size) or self.last_error error = self.get_error(tracked_items, items_completed, main_q_size) or self.last_error
if (main_q_size == 0 and num_processing_jobs == 0 and if (main_q_size == 0 and num_processing_jobs == 0 and
...@@ -184,10 +186,10 @@ class KubeJobStreamProgress(Plugin): ...@@ -184,10 +186,10 @@ class KubeJobStreamProgress(Plugin):
self.LOG.log("Replicas: %s" % replicas) self.LOG.log("Replicas: %s" % replicas)
self.LOG.log("Queue size: %s" % main_q_size) self.LOG.log("Queue size: %s" % main_q_size)
self.LOG.log("Pods Processins: %s" % num_processing_jobs) self.LOG.log("Pods Processins: %s" % num_processing_jobs)
tracked_items = num_processing_jobs + items_completed
tracked_items += main_q_size
self.LOG.log("Tracked items : %s" % (tracked_items)) self.LOG.log("Tracked items : %s" % (tracked_items))
self.LOG.log("Flux : %s" % (flux)) self.LOG.log("Input Flux : %s" % (input_lux))
self.LOG.log("Output Flux : %s" % (output_flux))
self.LOG.log("========================") self.LOG.log("========================")
application_progress_error = \ application_progress_error = \
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment