Fix chunk producer (TheSoftwareHouse#10)

homestars · Jun 16, 2020 · d1fb150 · d1fb150
1 parent be8b5a6
commit d1fb150
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/Fogger/Data/ChunkProducer.php b/src/Fogger/Data/ChunkProducer.php
@@ -43,24 +43,24 @@ private function queueTableChunks(Table $table)
 
         $counter = 0;
         $keys = [];
-        $last_key = null;
 
         while (($key = $result->fetchColumn()) !== False) {
             $keys[] = $key;
             $counter++;
+
             if (0 === $counter % $table->getChunkSize()) {
+                $last_key = null;
+
+                $this->chunkCache->pushMessage($table, $keys);
 
                 do {
                     $last_key = $key;
                     $key = $result->fetchColumn();
-                    $counter++;
                 } while ($last_key === $key);
 
-                $this->chunkCache->pushMessage($table, $keys);
                 $keys = [];
                 $keys[] = $key;
             }
-            $last_key = $key;
         }
         if (0 !== $counter % $table->getChunkSize()) {
             $this->chunkCache->pushMessage($table, $keys);