Merge pull request #45 from itkg-canne/fix-max-concurrent-jobs

[BUGFIX] Do not process channels beyond max concurrent jobs count limit.
itkg · Aug 17, 2017 · 07b112c · 07b112c
2 parents ae2458a + 01e2f0f
commit 07b112c
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/Command/ProcessDynamicChannelCommand.php b/Command/ProcessDynamicChannelCommand.php
@@ -147,6 +147,7 @@ protected function execute(InputInterface $input, OutputInterface $output)
                     $channel
                 )
             );
+            return;
         }
 
         $groupFieldIdentifierListToProcess = array_slice(
@@ -155,7 +156,7 @@ protected function execute(InputInterface $input, OutputInterface $output)
                 $lockNames
             ),
             0,
-            $input->getOption('concurrent-jobs-count')
+            $concurrentAvailableSlotsCount
         );
 
         foreach ($groupFieldIdentifierListToProcess as $identifier) {