Chunck parallel processes better

SU-SWS · Mar 7, 2024 · 6362e51 · 6362e51
1 parent a2a3e7b
commit 6362e51
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/src/Blt/Plugin/Commands/SwsCommands.php b/src/Blt/Plugin/Commands/SwsCommands.php
@@ -386,7 +386,16 @@ public function postCodeDeployUpdate($target_env, $deployed_tag, $options = ['no
     $sites = $this->getConfigValue('multisites');
     $parallel_executions = (int) getenv('UPDATE_PARALLEL_PROCESSES') ?: 10;
 
-    $site_chunks = array_chunk($sites, ceil(count($sites) / $parallel_executions));
+    $i = 0;
+    while ($sites) {
+      $site = array_splice($sites, 0, 1);
+      $site_chunks[$i][] = reset($site);
+      $i++;
+      if ($i >= $parallel_executions) {
+        $i = 0;
+      }
+    }
+
     $commands = [];
     foreach ($site_chunks as $sites) {
       $command = $this->blt()
@@ -398,6 +407,7 @@ public function postCodeDeployUpdate($target_env, $deployed_tag, $options = ['no
       }
       $commands[] = $command->getCommand();
     }
+
     file_put_contents(sys_get_temp_dir() . '/success-report.txt', '');
     file_put_contents(sys_get_temp_dir() . '/failed-report.txt', '');