Commit d8900954 authored by Ignacio's avatar Ignacio
Browse files

fixing

parent 5019c9cb
......@@ -92,7 +92,7 @@ class KubeJobStreamProgress(Plugin):
else:
raise ex.BadRequestException("Unknown datasource type...!")
def get_error(self, tracked_items, completed_items, main_q_size):
def get_error(self, tracked_items, completed_items, main_q_size, replicas):
input_flux = (tracked_items - self.last_tracked_items)/self.collect_period
real_output_flux = (completed_items - self.last_completed_items)/self.collect_period
......@@ -193,7 +193,7 @@ class KubeJobStreamProgress(Plugin):
real_output_flux = (items_completed - self.last_completed_items)/self.collect_period
expected_output_flux = replicas/self.expected_time
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, replicas) or self.last_error
if (main_q_size == 0 and num_processing_jobs == 0 and
replicas == self.min_rep):
......
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