show

stream_kubejobs/__init__.py

@@ -185,7 +185,8 @@ class KubeJobStreamProgress(Plugin):
                 pipe = self.rds.pipeline()
                 pipe.get('job:inserted_count')
                 pipe.get('job:completed_count')
-                inserted_items, items_completed = pipe.execute()
+                pipe.llen("job")
+                inserted_items, items_completed, main_q_size = pipe.execute()
 
                 inserted_items = int(inserted_items) if inserted_items != None else 0
                 items_completed = int(items_completed) if items_completed != None else 0