show

stream_kubejobs/__init__.py

@@ -183,8 +183,8 @@ class KubeJobStreamProgress(Plugin):
                 timestamp = time.time() * 1000
 
                 pipe = self.rds.pipeline()
-                pipe.llen('job:inserted_count')
-                pipe.llen('job:completed_count')
+                pipe.get('job:inserted_count')
+                pipe.get('job:completed_count')
                 inserted_items, items_completed = pipe.execute()
 
                 replicas = self._get_num_replicas() or self.last_replicas