Commit 21b62cdb authored by Ignacio's avatar Ignacio
Browse files

correcting corrector term

parent b1f36942
......@@ -101,11 +101,14 @@ class KubeJobStreamProgress(Plugin):
error0 = real_output_flux - input_flux
error1 = expected_output_flux - input_flux
corrector_term0 = (0.5 if main_q_size/self.collect_period > input_flux*2 else 0) #This term exist to make the queue decrease
corrector_term = 0 if self.corrector_term else corrector_term0
current_error = error1 if self.error_option else error0
error = current_error - corrector_term
corrector_term_check = True if main_q_size/self.expected_time > input_flux*2 else False #This term exist to make the queue decrease
error = current_error
if self.corrector_term and corrector_term_check:
error = 0.5
self.last_inserted_items = inserted_items
self.last_completed_items = completed_items
......
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