Commit 72db3c6c authored by Ignacio's avatar Ignacio
Browse files

correcting to working version

parent b754b4a9
......@@ -120,8 +120,8 @@ class KubeJobStreamProgress(Plugin):
replicas, main_q_size):
items_flux = (tracked_items - self.tracked_items)/self.collect_period
items_flux = items_flux * (4/6)
error = replicas/self.expected_time - items_flux - (0.5 if main_q_size > items_flux*1.5 else 0)
items_flux = items_flux
error = replicas/self.expected_time - items_flux - (0.5 if main_q_size/self.collect_period > (replicas)*2 else 0)
self.tracked_items = tracked_items
self.last_error = error
return 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