Auto correct queues table if there are items when there shouldn't be any

tripal · Apr 1, 2019 · 59e716e · 59e716e
1 parent 46d5799
commit 59e716e
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/includes/Elasticsearch/ESQueue.php b/includes/Elasticsearch/ESQueue.php
@@ -57,7 +57,7 @@ public static function progress() {
     $should_check = (int) db_query("SELECT COUNT(*) 
                                     FROM queue 
                                     WHERE name LIKE :es", [
-      ':es' => db_like('elasticsearch').'%',
+      ':es' => db_like('elasticsearch') . '%',
     ])->fetchField();
 
     $queues = [];
@@ -73,6 +73,9 @@ public static function progress() {
                     ORDER BY index_name ASC, priority ASC';
       $queues = db_query($query)->fetchAll();
     }
+    elseif (intval(db_query('SELECT COUNT(*) FROM {' . self::QUEUE_TABLE . '} WHERE completed < total')->fetchField())) {
+      db_query('UPDATE {' . self::QUEUE_TABLE . '} SET completed = total')->fetchAll();
+    }
 
     $progress = [];
     $total = 0;