show

stream_kubejobs/__init__.py

@@ -185,8 +185,9 @@ class KubeJobStreamProgress(Plugin):
                 pipe = self.rds.pipeline()
                 pipe.get('job:inserted_count')
                 pipe.get('job:completed_count')
-                pipe.llen("job")
-                inserted_items, items_completed, main_q_size = pipe.execute()
+                pipe.get('job:processing')
+                pipe.llen('job')
+                inserted_items, items_completed, num_processing_jobs, 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
@@ -212,10 +213,10 @@ class KubeJobStreamProgress(Plugin):
                 self.LOG.log("Correction term: %s" % corrector_term)
                 self.LOG.log("Error: %s" % error)
                 self.LOG.log("Replicas: %s" % replicas)
+                self.LOG.log("Inserted items : %i" % inserted_items)
                 self.LOG.log("Queue size: %s" % main_q_size)
                 self.LOG.log("Pods Processins: %s" % num_processing_jobs)
                 self.LOG.log("Items Completed: %i" % items_completed)
-                self.LOG.log("Inserted items : %i" % inserted_items)
                 self.LOG.log("Input Flux : %s" % input_flux)
                 self.LOG.log("Real output Flux : %s" % real_output_flux)
                 self.LOG.log("Expected output Flux : %s" % expected_output_flux)