Commit dd1eb598 authored by Ignacio's avatar Ignacio
Browse files

show

parent f35aed22
......@@ -185,13 +185,13 @@ class KubeJobStreamProgress(Plugin):
pipe = self.rds.pipeline()
pipe.get('job:inserted_count')
pipe.get('job:completed_count')
inserted_items, items_completed = map(int, pipe.execute())
inserted_items, items_completed = pipe.execute()
inserted_items = int(inserted_items) if inserted_items != None else 0
items_completed = int(items_completed) if items_completed != None else 0
replicas = self._get_num_replicas() or self.last_replicas
self.last_replicas = replicas
input_flux = (inserted_items - self.last_inserted_items)/self.collect_period
real_output_flux = (items_completed - self.last_completed_items)/self.collect_period
expected_output_flux = replicas/self.expected_time
error = self.get_error(inserted_items, items_completed, main_q_size, replicas) or self.last_error
......@@ -200,6 +200,9 @@ class KubeJobStreamProgress(Plugin):
timestamp = self.last_timestamp
input_flux = (inserted_items - self.last_inserted_items)/self.collect_period
real_output_flux = (items_completed - self.last_completed_items)/self.collect_period
expected_output_flux = replicas/self.expected_time
error_option = "Expected output" if self.error_option else "Real output"
corrector_term = "No" if self.corrector_term else "Yes"
self.last_timestamp = timestamp
......
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