Always check for dynamic concurrency environment when setting worker count (#8570)

Author: liliankasem

src/WebJobs.Script/Workers/Rpc/FunctionRegistration/RpcFunctionInvocationDispatcher.cs

@@ -117,13 +117,13 @@ private async Task<int> GetMaxProcessCount()
                 return MultiLanguageDefaultProcessCount;
             }
 
-            if (_workerConcurrencyOptions != null && !string.IsNullOrEmpty(_workerRuntime))
+            if (!string.IsNullOrEmpty(_workerRuntime))
             {
                 var workerConfig = _workerConfigs.Where(c => c.Description.Language.Equals(_workerRuntime, StringComparison.InvariantCultureIgnoreCase))
-                                                 .FirstOrDefault();
+                                                .FirstOrDefault();
                 if (workerConfig != null)
                 {
-                    return _environment.IsWorkerDynamicConcurrencyEnabled() ? _workerConcurrencyOptions.Value.MaxWorkerCount : workerConfig.CountOptions.ProcessCount;
+                    return workerConfig.CountOptions.ProcessCount;
                 }
             }
 
@@ -490,7 +490,7 @@ internal async Task<IEnumerable<IRpcWorkerChannel>> GetInitializedWorkerChannels
             IEnumerable<IRpcWorkerChannel> workerChannels = await GetAllWorkerChannelsAsync(language);
             IEnumerable<IRpcWorkerChannel> initializedWorkers = workerChannels.Where(ch => ch.IsChannelReadyForInvocations());
 
-            int workerCount = await _maxProcessCount.Value;
+            int workerCount = _environment.IsWorkerDynamicConcurrencyEnabled() ? _workerConcurrencyOptions.Value.MaxWorkerCount : await _maxProcessCount.Value;
             if (initializedWorkers.Count() > workerCount)
             {
                 throw new InvalidOperationException($"Number of initialized language workers exceeded:{initializedWorkers.Count()} exceeded maxProcessCount: {workerCount}");