Minor

mtcextendee · Jul 27, 2019 · 4bf2157 · 4bf2157
1 parent 814bc76
commit 4bf2157
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/Import/ImportFromDirectory.php b/Import/ImportFromDirectory.php
@@ -54,6 +54,7 @@ public function importFromFiles(array $options)
         $this->fileSystem         = new Filesystem();
         foreach ($files as $file) {
             $this->importFromFile($file, $importTemplate);
+            sleep(1);
         }
 
         return $files;

diff --git a/Import/ParallelImport.php b/Import/ParallelImport.php
@@ -36,8 +36,8 @@ public function parallelImport(array $options)
         $parallelLimit = $this->importModel->getParallelImportLimit();
         $processSet    = [];
         for ($i = 0; $i < $parallelLimit; $i++) {
-            if (!$this->importModel->checkParallelImportLimit()) {
-                break;
+            if (!$this->importModel->getImportToProcess() || !$this->importModel->checkParallelImportLimit()) {
+                continue;
             }
             $builder = (new ProcessBuilder())
                 ->setPrefix('php')