updating error

stream_kubejobs/__init__.py

@@ -105,7 +105,7 @@ class KubeJobStreamProgress(Plugin):
         corrector_term = 0 if self.corrector_term else corrector_term0
 
         current_error = error1 if self.error_option else error0
-        error = items_output_flux - input_flux - corrector_term
+        error = current_error - corrector_term
 
         self.last_tracked_items = tracked_items
         self.last_completed_items = completed_items