diff --git a/Command/ProcessDynamicChannelCommand.php b/Command/ProcessDynamicChannelCommand.php index 087260f..1b8bdc2 100644 --- 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) {