improve sync node handling

chevere · Oct 29, 2023 · 451334e · 451334e
1 parent d0738d3
commit 451334e
Showing 1 changed file with 9 additions and 10 deletions.
diff --git a/src/Runner.php b/src/Runner.php
@@ -49,19 +49,18 @@ public function withRun(): RunnerInterface
         $new = clone $this;
         $jobs = $new->run->workflow()->jobs();
         $graph = $jobs->graph()->toArray();
-        if (count($graph) === count($jobs)) {
-            foreach ($graph as $node) {
+        foreach ($graph as $node) {
+            if (count($node) === 1) {
                 $runner = runnerForJob($new, $node[0]);
                 $new->merge($new, $runner);
+
+                continue;
             }
-        } else {
-            foreach ($graph as $node) {
-                $promises = $new->getPromises($node);
-                /** @var RunnerInterface[] $responses */
-                $responses = wait(all($promises));
-                foreach ($responses as $runner) {
-                    $new->merge($new, $runner);
-                }
+            $promises = $new->getPromises($node);
+            /** @var RunnerInterface[] $responses */
+            $responses = wait(all($promises));
+            foreach ($responses as $runner) {
+                $new->merge($new, $runner);
             }
         }