diff --git a/includes/Elasticsearch/ESQueue.php b/includes/Elasticsearch/ESQueue.php index bb65ef83..83d4acee 100644 --- 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;