show

stream_kubejobs/__init__.py

@@ -196,7 +196,7 @@ class KubeJobStreamProgress(Plugin):
                 pipe = self.rds.pipeline()
                 pipe.llen('job')
                 pipe.llen('job:processing')
-                pipe.llen('job:results')
+                pipe.scard('job:results')
                 main_q_size, num_processing_jobs,items_completed = pipe.execute()
 
                 replicas = self._get_num_replicas() or self.last_replicas