time shifting

stream_kubejobs/__init__.py

@@ -120,6 +120,7 @@ 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)
         self.tracked_items = tracked_items
         self.last_error = error