show

stream_kubejobs/__init__.py

@@ -185,7 +185,7 @@ class KubeJobStreamProgress(Plugin):
                 pipe = self.rds.pipeline()
                 pipe.get('job:inserted_count')
                 pipe.get('job:completed_count')
-                pipe.get('job:processing')
+                pipe.llen('job:processing')
                 pipe.llen('job')
                 inserted_items, items_completed, num_processing_jobs, main_q_size = pipe.execute()