Register profile manager at webhost scope (#8779)

liliankasem · web-flow · commit 0f6871b14e65 · 2022-09-22T17:15:37.000-07:00
diff --git a/src/WebJobs.Script/ScriptHostBuilderExtensions.cs b/src/WebJobs.Script/ScriptHostBuilderExtensions.cs
@@ -340,6 +340,7 @@ public static void AddCommonServices(IServiceCollection services)
             services.AddSingleton<HostIdValidator>();
             services.AddSingleton<IHostIdProvider, ScriptHostIdProvider>();
             services.TryAddSingleton<IScriptEventManager, ScriptEventManager>();
+            services.AddSingleton<IWorkerProfileManager, WorkerProfileManager>();
 
             // Add Language Worker Service
             // Need to maintain the order: Add RpcInitializationService before core script host services
diff --git a/src/WebJobs.Script/Workers/Profiles/WorkerDescriptionProfile.cs b/src/WebJobs.Script/Workers/Profiles/WorkerDescriptionProfile.cs
@@ -70,17 +70,18 @@ public bool EvaluateConditions()
         }
 
         /// <summary>
-        /// Overrides the worker description parameters to that available in the profile
+        /// Creates a new worker description and overrides parameters with those available in the profile
         /// </summary>
-        public RpcWorkerDescription ApplyProfile(RpcWorkerDescription workerDescription)
+        public RpcWorkerDescription ApplyProfile(RpcWorkerDescription defaultWorkerDescription)
         {
-            workerDescription.Arguments = UseProfileOrDefault(ProfileDescription.Arguments, workerDescription.Arguments);
-            workerDescription.DefaultExecutablePath = UseProfileOrDefault(ProfileDescription.DefaultExecutablePath, workerDescription.DefaultExecutablePath);
-            workerDescription.DefaultWorkerPath = UseProfileOrDefault(ProfileDescription.DefaultWorkerPath, workerDescription.DefaultWorkerPath);
-            workerDescription.Extensions = UseProfileOrDefault(ProfileDescription.Extensions, workerDescription.Extensions) as List<string>;
-            workerDescription.Language = UseProfileOrDefault(ProfileDescription.Language, workerDescription.Language);
-            workerDescription.WorkerDirectory = UseProfileOrDefault(ProfileDescription.WorkerDirectory, workerDescription.WorkerDirectory);
-            return workerDescription;
+            RpcWorkerDescription updatedDescription = new ();
+            updatedDescription.Arguments = UseProfileOrDefault(ProfileDescription.Arguments, defaultWorkerDescription.Arguments);
+            updatedDescription.DefaultExecutablePath = UseProfileOrDefault(ProfileDescription.DefaultExecutablePath, defaultWorkerDescription.DefaultExecutablePath);
+            updatedDescription.DefaultWorkerPath = UseProfileOrDefault(ProfileDescription.DefaultWorkerPath, defaultWorkerDescription.DefaultWorkerPath);
+            updatedDescription.Extensions = UseProfileOrDefault(ProfileDescription.Extensions, defaultWorkerDescription.Extensions) as List<string>;
+            updatedDescription.Language = UseProfileOrDefault(ProfileDescription.Language, defaultWorkerDescription.Language);
+            updatedDescription.WorkerDirectory = UseProfileOrDefault(ProfileDescription.WorkerDirectory, defaultWorkerDescription.WorkerDirectory);
+            return updatedDescription;
         }
 
         private string UseProfileOrDefault(string profileParameter, string defaultParameter)
diff --git a/src/WebJobs.Script/Workers/Profiles/WorkerProfileManager.cs b/src/WebJobs.Script/Workers/Profiles/WorkerProfileManager.cs
@@ -1,5 +1,5 @@
 // Copyright (c) .NET Foundation. All rights reserved.
-// Licensed under the Apache License, Version 2.0. See License.txt in the project root for license information.
+// Licensed under the MIT License, Version 2.0. See License.txt in the project root for license information.
 
 using System;
 using System.Collections.Generic;
@@ -15,16 +15,22 @@ namespace Microsoft.Azure.WebJobs.Script.Workers
     internal class WorkerProfileManager : IWorkerProfileManager
     {
         private readonly ILogger _logger;
+        private readonly IEnvironment _environment;
         private readonly IEnumerable<IWorkerProfileConditionProvider> _conditionProviders;
+
+        private string _activeProfile = string.Empty;
         private Dictionary<string, List<WorkerDescriptionProfile>> _profiles;
-        private string _activeProfile;
 
-        public WorkerProfileManager(ILogger logger, IEnumerable<IWorkerProfileConditionProvider> conditionProviders)
+        public WorkerProfileManager(ILogger<WorkerProfileManager> logger, IEnvironment environment)
         {
+            _environment = environment ?? throw new ArgumentNullException(nameof(environment));
             _logger = logger ?? throw new ArgumentNullException(nameof(logger));
-            _conditionProviders = conditionProviders ?? throw new ArgumentNullException(nameof(conditionProviders));
+
             _profiles = new Dictionary<string, List<WorkerDescriptionProfile>>();
-            _activeProfile = string.Empty;
+            _conditionProviders = new List<IWorkerProfileConditionProvider>
+            {
+                new WorkerProfileConditionProvider(_logger, _environment)
+            };
         }
 
         /// <inheritdoc />
@@ -59,9 +65,11 @@ public void LoadWorkerDescriptionFromProfiles(RpcWorkerDescription defaultWorker
                 _logger?.LogInformation($"Worker initialized with profile - {profile.Name}, Profile ID {profile.ProfileId} from worker config.");
                 _activeProfile = profile.ProfileId;
                 workerDescription = profile.ApplyProfile(defaultWorkerDescription);
-                return;
             }
-            workerDescription = defaultWorkerDescription;
+            else
+            {
+                workerDescription = defaultWorkerDescription;
+            }
         }
 
         /// <inheritdoc />
@@ -87,7 +95,7 @@ public bool IsCorrectProfileLoaded(string workerRuntime)
             var profileId = string.Empty;
             if (GetEvaluatedProfile(workerRuntime, out WorkerDescriptionProfile profile))
             {
-               profileId = profile.ProfileId;
+                profileId = profile.ProfileId;
             }
             return _activeProfile.Equals(profileId);
         }
diff --git a/src/WebJobs.Script/Workers/Rpc/Configuration/LanguageWorkerOptionsSetup.cs b/src/WebJobs.Script/Workers/Rpc/Configuration/LanguageWorkerOptionsSetup.cs
@@ -4,6 +4,7 @@
 using System;
 using System.Collections.Generic;
 using Microsoft.Azure.WebJobs.Script.Diagnostics;
+using Microsoft.Azure.WebJobs.Script.Workers.Profiles;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Options;
@@ -16,11 +17,13 @@ internal class LanguageWorkerOptionsSetup : IConfigureOptions<LanguageWorkerOpti
         private readonly ILogger _logger;
         private readonly IEnvironment _environment;
         private readonly IMetricsLogger _metricsLogger;
+        private readonly IWorkerProfileManager _workerProfileManager;
 
         public LanguageWorkerOptionsSetup(IConfiguration configuration,
                                           ILoggerFactory loggerFactory,
                                           IEnvironment environment,
-                                          IMetricsLogger metricsLogger)
+                                          IMetricsLogger metricsLogger,
+                                          IWorkerProfileManager workerProfileManager)
         {
             if (loggerFactory is null)
             {
@@ -30,6 +33,7 @@ public LanguageWorkerOptionsSetup(IConfiguration configuration,
             _configuration = configuration ?? throw new ArgumentNullException(nameof(configuration));
             _environment = environment ?? throw new ArgumentNullException(nameof(environment));
             _metricsLogger = metricsLogger ?? throw new ArgumentNullException(nameof(metricsLogger));
+            _workerProfileManager = workerProfileManager ?? throw new ArgumentNullException(nameof(workerProfileManager));
 
             _logger = loggerFactory.CreateLogger("Host.LanguageWorkerConfig");
         }
@@ -44,7 +48,7 @@ public void Configure(LanguageWorkerOptions options)
                 return;
             }
 
-            var configFactory = new RpcWorkerConfigFactory(_configuration, _logger, SystemRuntimeInformation.Instance, _environment, _metricsLogger);
+            var configFactory = new RpcWorkerConfigFactory(_configuration, _logger, SystemRuntimeInformation.Instance, _environment, _metricsLogger, _workerProfileManager);
             options.WorkerConfigs = configFactory.GetConfigs();
         }
     }
diff --git a/src/WebJobs.Script/Workers/Rpc/Configuration/RpcWorkerConfigFactory.cs b/src/WebJobs.Script/Workers/Rpc/Configuration/RpcWorkerConfigFactory.cs
@@ -10,7 +10,6 @@
 using Microsoft.Azure.WebJobs.Script.Workers.Profiles;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.Logging;
-using Newtonsoft.Json;
 using Newtonsoft.Json.Linq;
 
 namespace Microsoft.Azure.WebJobs.Script.Workers.Rpc
@@ -32,22 +31,17 @@ public RpcWorkerConfigFactory(IConfiguration config,
                                         ILogger logger,
                                         ISystemRuntimeInformation systemRuntimeInfo,
                                         IEnvironment environment,
-                                        IMetricsLogger metricsLogger)
+                                        IMetricsLogger metricsLogger,
+                                        IWorkerProfileManager workerProfileManager)
         {
             _config = config ?? throw new ArgumentNullException(nameof(config));
             _logger = logger ?? throw new ArgumentNullException(nameof(logger));
             _systemRuntimeInformation = systemRuntimeInfo ?? throw new ArgumentNullException(nameof(systemRuntimeInfo));
             _environment = environment ?? throw new ArgumentNullException(nameof(environment));
-            _metricsLogger = metricsLogger;
+            _metricsLogger = metricsLogger ?? throw new ArgumentNullException(nameof(metricsLogger));
+            _profileManager = workerProfileManager ?? throw new ArgumentNullException(nameof(workerProfileManager));
             _workerRuntime = _environment.GetEnvironmentVariable(RpcWorkerConstants.FunctionWorkerRuntimeSettingName);
 
-            var conditionProviders = new List<IWorkerProfileConditionProvider>
-            {
-                new WorkerProfileConditionProvider(_logger, _environment)
-            };
-
-            _profileManager = new WorkerProfileManager(_logger, conditionProviders);
-
             WorkersDirPath = GetDefaultWorkersDirectory(Directory.Exists);
             var workersDirectorySection = _config.GetSection($"{RpcWorkerConstants.LanguageWorkersSectionName}:{WorkerConstants.WorkersDirectorySectionName}");
 
diff --git a/src/WebJobs.Script/Workers/Rpc/WebHostRpcWorkerChannelManager.cs b/src/WebJobs.Script/Workers/Rpc/WebHostRpcWorkerChannelManager.cs
@@ -21,7 +21,7 @@ public class WebHostRpcWorkerChannelManager : IWebHostRpcWorkerChannelManager
         private readonly ILogger _logger = null;
         private readonly TimeSpan workerInitTimeout = TimeSpan.FromSeconds(30);
         private readonly IOptionsMonitor<ScriptApplicationHostOptions> _applicationHostOptions = null;
-        private readonly IOptionsMonitor<LanguageWorkerOptions> _lanuageworkerOptions = null;
+        private readonly IOptionsMonitor<LanguageWorkerOptions> _languageWorkerOptions = null;
         private readonly IScriptEventManager _eventManager = null;
         private readonly IEnvironment _environment;
         private readonly ILoggerFactory _loggerFactory = null;
@@ -40,22 +40,20 @@ public WebHostRpcWorkerChannelManager(IScriptEventManager eventManager,
                                               IRpcWorkerChannelFactory rpcWorkerChannelFactory,
                                               IOptionsMonitor<ScriptApplicationHostOptions> applicationHostOptions,
                                               IMetricsLogger metricsLogger, IOptionsMonitor<LanguageWorkerOptions> languageWorkerOptions,
-                                              IConfiguration config)
+                                              IConfiguration config,
+                                              IWorkerProfileManager workerProfileManager)
         {
             _environment = environment ?? throw new ArgumentNullException(nameof(environment));
+            _config = config ?? throw new ArgumentNullException(nameof(config));
+            _profileManager = workerProfileManager ?? throw new ArgumentNullException(nameof(workerProfileManager));
             _eventManager = eventManager;
             _loggerFactory = loggerFactory;
             _metricsLogger = metricsLogger;
             _rpcWorkerChannelFactory = rpcWorkerChannelFactory;
             _logger = loggerFactory.CreateLogger<WebHostRpcWorkerChannelManager>();
             _applicationHostOptions = applicationHostOptions;
-            _lanuageworkerOptions = languageWorkerOptions;
-            _config = config ?? throw new ArgumentNullException(nameof(config));
-            var conditionProviders = new List<IWorkerProfileConditionProvider>
-            {
-                new WorkerProfileConditionProvider(_logger, _environment)
-            };
-            _profileManager = new WorkerProfileManager(_logger, conditionProviders);
+            _languageWorkerOptions = languageWorkerOptions;
+
             _shutdownStandbyWorkerChannels = ScheduleShutdownStandbyChannels;
             _shutdownStandbyWorkerChannels = _shutdownStandbyWorkerChannels.Debounce(milliseconds: 5000);
         }
@@ -73,7 +71,7 @@ internal async Task<IRpcWorkerChannel> InitializeLanguageWorkerChannel(string ru
             _logger.LogDebug("Creating language worker channel for runtime:{runtime}", runtime);
             try
             {
-                rpcWorkerChannel = _rpcWorkerChannelFactory.Create(scriptRootPath, runtime, _metricsLogger, 0, _lanuageworkerOptions.CurrentValue.WorkerConfigs);
+                rpcWorkerChannel = _rpcWorkerChannelFactory.Create(scriptRootPath, runtime, _metricsLogger, 0, _languageWorkerOptions.CurrentValue.WorkerConfigs);
                 AddOrUpdateWorkerChannels(runtime, rpcWorkerChannel);
                 await rpcWorkerChannel.StartWorkerProcessAsync().ContinueWith(processStartTask =>
                 {
@@ -159,9 +157,9 @@ private bool UsePlaceholderChannel(string workerRuntime)
             // Special case: node and PowerShell apps must be read-only to use the placeholder mode channel
             // Also cannot use placeholder worker that is targeting ~3 but has backwards compatibility with V2 enabled
             // TODO: Remove special casing when resolving https://github.com/Azure/azure-functions-host/issues/4534
-            if (workerRuntime.ToLowerInvariant() is RpcWorkerConstants.NodeLanguageWorkerName
-                or RpcWorkerConstants.PowerShellLanguageWorkerName
-                or RpcWorkerConstants.PythonLanguageWorkerName)
+            if (string.Equals(workerRuntime, RpcWorkerConstants.NodeLanguageWorkerName, StringComparison.OrdinalIgnoreCase)
+                || string.Equals(workerRuntime, RpcWorkerConstants.PowerShellLanguageWorkerName, StringComparison.OrdinalIgnoreCase)
+                || string.Equals(workerRuntime, RpcWorkerConstants.PythonLanguageWorkerName, StringComparison.OrdinalIgnoreCase))
             {
                 // Use if readonly and not v2 compatible on ~3 extension
                 return _applicationHostOptions.CurrentValue.IsFileSystemReadOnly && !_environment.IsV2CompatibleOnV3Extension();
diff --git a/test/WebJobs.Script.Tests/Configuration/LanguageWorkerOptionsSetupTests.cs b/test/WebJobs.Script.Tests/Configuration/LanguageWorkerOptionsSetupTests.cs
@@ -3,9 +3,11 @@
 
 using System;
 using Microsoft.Azure.WebJobs.Script.Workers;
+using Microsoft.Azure.WebJobs.Script.Workers.Profiles;
 using Microsoft.Azure.WebJobs.Script.Workers.Rpc;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.Logging.Abstractions;
+using Moq;
 using Xunit;
 
 namespace Microsoft.Azure.WebJobs.Script.Tests.Configuration
@@ -21,17 +23,22 @@ public void LanguageWorkerOptions_Expected_ListOfConfigs(string workerRuntime)
         {
             var runtimeInfo = new TestSystemRuntimeInformation();
             var testEnvironment = new TestEnvironment();
+            var testMetricLogger = new TestMetricsLogger();
             var configurationBuilder = new ConfigurationBuilder()
                 .Add(new ScriptEnvironmentVariablesConfigurationSource());
-
             var configuration = configurationBuilder.Build();
+            var testProfileManager = new Mock<IWorkerProfileManager>();
+
             if (!string.IsNullOrEmpty(workerRuntime))
             {
                 testEnvironment.SetEnvironmentVariable(RpcWorkerConstants.FunctionWorkerRuntimeSettingName, workerRuntime);
             }
-            LanguageWorkerOptionsSetup setup = new LanguageWorkerOptionsSetup(configuration, NullLoggerFactory.Instance, testEnvironment, new TestMetricsLogger());
+
+            LanguageWorkerOptionsSetup setup = new LanguageWorkerOptionsSetup(configuration, NullLoggerFactory.Instance, testEnvironment, testMetricLogger, testProfileManager.Object);
             LanguageWorkerOptions options = new LanguageWorkerOptions();
+
             setup.Configure(options);
+
             if (string.IsNullOrEmpty(workerRuntime))
             {
                 Assert.Equal(4, options.WorkerConfigs.Count);
diff --git a/test/WebJobs.Script.Tests/Workers/Profiles/EnvironmentConditionTests.cs b/test/WebJobs.Script.Tests/Workers/Profiles/EnvironmentConditionTests.cs
@@ -1,5 +1,5 @@
 // Copyright (c) .NET Foundation. All rights reserved.
-// Licensed under the Apache License, Version 2.0. See License.txt in the project root for license information.
+// Licensed under the MIT License. See License.txt in the project root for license information.
 
 using System;
 using System.ComponentModel.DataAnnotations;
diff --git a/test/WebJobs.Script.Tests/Workers/Profiles/FalseConditionTests.cs b/test/WebJobs.Script.Tests/Workers/Profiles/FalseConditionTests.cs
@@ -1,5 +1,5 @@
 // Copyright (c) .NET Foundation. All rights reserved.
-// Licensed under the Apache License, Version 2.0. See License.txt in the project root for license information.
+// Licensed under the MIT License. See License.txt in the project root for license information.
 
 using Microsoft.Azure.WebJobs.Script.Workers.Profiles;
 using Xunit;
diff --git a/test/WebJobs.Script.Tests/Workers/Profiles/HostPropertyConditionTests.cs b/test/WebJobs.Script.Tests/Workers/Profiles/HostPropertyConditionTests.cs
@@ -1,5 +1,5 @@
 // Copyright (c) .NET Foundation. All rights reserved.
-// Licensed under the Apache License, Version 2.0. See License.txt in the project root for license information.
+// Licensed under the MIT License. See License.txt in the project root for license information.
 
 using System.ComponentModel.DataAnnotations;
 using Microsoft.Azure.WebJobs.Script.Workers;
diff --git a/test/WebJobs.Script.Tests/Workers/Profiles/ProfilesTestUtilities.cs b/test/WebJobs.Script.Tests/Workers/Profiles/ProfilesTestUtilities.cs
@@ -1,11 +1,9 @@
 ﻿// Copyright (c) .NET Foundation. All rights reserved.
 // Licensed under the MIT License. See License.txt in the project root for license information.
 
-using System;
-using System.Collections.Generic;
-using Microsoft.Azure.WebJobs.Script.Tests.Workers.Rpc;
 using Microsoft.Azure.WebJobs.Script.Workers;
 using Microsoft.Azure.WebJobs.Script.Workers.Profiles;
+using Microsoft.Extensions.Logging;
 using Newtonsoft.Json.Linq;
 
 namespace Microsoft.Azure.WebJobs.Script.Tests.Workers.Profiles
@@ -27,7 +25,7 @@ public static WorkerProfileConditionDescriptor GetTestWorkerProfileConditionDesc
             return condition.ToObject<WorkerProfileConditionDescriptor>();
         }
 
-        public static EnvironmentCondition GetTestEnvironmentCondition(TestLogger logger, TestEnvironment testEnvironment, string name, string expression)
+        public static EnvironmentCondition GetTestEnvironmentCondition(ILogger logger, TestEnvironment testEnvironment, string name, string expression)
         {
             var descriptor = new WorkerProfileConditionDescriptor();
             descriptor.Type = WorkerConstants.WorkerDescriptionProfileEnvironmentCondition;
@@ -37,7 +35,7 @@ public static EnvironmentCondition GetTestEnvironmentCondition(TestLogger logger
             return new EnvironmentCondition(logger, testEnvironment, descriptor);
         }
 
-        public static HostPropertyCondition GetTestHostPropertyCondition(TestLogger logger, TestSystemRuntimeInformation testSystemRuntimeInfo, string name, string expression)
+        public static HostPropertyCondition GetTestHostPropertyCondition(ILogger logger, TestSystemRuntimeInformation testSystemRuntimeInfo, string name, string expression)
         {
             var descriptor = new WorkerProfileConditionDescriptor();
             descriptor.Type = WorkerConstants.WorkerDescriptionProfileHostPropertyCondition;
diff --git a/test/WebJobs.Script.Tests/Workers/Profiles/WorkerDescriptionProfileTests.cs b/test/WebJobs.Script.Tests/Workers/Profiles/WorkerDescriptionProfileTests.cs
@@ -1,5 +1,5 @@
 // Copyright (c) .NET Foundation. All rights reserved.
-// Licensed under the Apache License, Version 2.0. See License.txt in the project root for license information.
+// Licensed under the MIT License. See License.txt in the project root for license information.
 
 using System.Collections.Generic;
 using System.ComponentModel.DataAnnotations;
diff --git a/test/WebJobs.Script.Tests/Workers/Profiles/WorkerProfileConditionDescriptorTests.cs b/test/WebJobs.Script.Tests/Workers/Profiles/WorkerProfileConditionDescriptorTests.cs
@@ -1,5 +1,5 @@
 // Copyright (c) .NET Foundation. All rights reserved.
-// Licensed under the Apache License, Version 2.0. See License.txt in the project root for license information.
+// Licensed under the MIT License. See License.txt in the project root for license information.
 
 using Microsoft.Azure.WebJobs.Script.Workers;
 using Microsoft.Azure.WebJobs.Script.Workers.Profiles;
diff --git a/test/WebJobs.Script.Tests/Workers/Profiles/WorkerProfileManagerTests.cs b/test/WebJobs.Script.Tests/Workers/Profiles/WorkerProfileManagerTests.cs
diff --git a/test/WebJobs.Script.Tests/Workers/Rpc/RpcWorkerConfigFactoryTests.cs b/test/WebJobs.Script.Tests/Workers/Rpc/RpcWorkerConfigFactoryTests.cs
diff --git a/test/WebJobs.Script.Tests/Workers/Rpc/RpcWorkerConfigTests.cs b/test/WebJobs.Script.Tests/Workers/Rpc/RpcWorkerConfigTests.cs
diff --git a/test/WebJobs.Script.Tests/Workers/Rpc/WebHostRpcWorkerChannelManagerTests.cs b/test/WebJobs.Script.Tests/Workers/Rpc/WebHostRpcWorkerChannelManagerTests.cs

Original file line number	Diff line number	Diff line change
`@@ -4,6 +4,7 @@`
`4`	`4`	`using System;`
`5`	`5`	`using System.Collections.Generic;`
`6`	`6`	`using Microsoft.Azure.WebJobs.Script.Diagnostics;`
	`7`	`+using Microsoft.Azure.WebJobs.Script.Workers.Profiles;`
`7`	`8`	`using Microsoft.Extensions.Configuration;`
`8`	`9`	`using Microsoft.Extensions.Logging;`
`9`	`10`	`using Microsoft.Extensions.Options;`
`@@ -16,11 +17,13 @@ internal class LanguageWorkerOptionsSetup : IConfigureOptions<LanguageWorkerOpti`
`16`	`17`	`private readonly ILogger _logger;`
`17`	`18`	`private readonly IEnvironment _environment;`
`18`	`19`	`private readonly IMetricsLogger _metricsLogger;`
	`20`	`+ private readonly IWorkerProfileManager _workerProfileManager;`
`19`	`21`
`20`	`22`	`public LanguageWorkerOptionsSetup(IConfiguration configuration,`
`21`	`23`	`ILoggerFactory loggerFactory,`
`22`	`24`	`IEnvironment environment,`
`23`		`- IMetricsLogger metricsLogger)`
	`25`	`+ IMetricsLogger metricsLogger,`
	`26`	`+ IWorkerProfileManager workerProfileManager)`
`24`	`27`	`{`
`25`	`28`	`if (loggerFactory is null)`
`26`	`29`	`{`
`@@ -30,6 +33,7 @@ public LanguageWorkerOptionsSetup(IConfiguration configuration,`
`30`	`33`	`_configuration = configuration ?? throw new ArgumentNullException(nameof(configuration));`
`31`	`34`	`_environment = environment ?? throw new ArgumentNullException(nameof(environment));`
`32`	`35`	`_metricsLogger = metricsLogger ?? throw new ArgumentNullException(nameof(metricsLogger));`
	`36`	`+ _workerProfileManager = workerProfileManager ?? throw new ArgumentNullException(nameof(workerProfileManager));`
`33`	`37`
`34`	`38`	`_logger = loggerFactory.CreateLogger("Host.LanguageWorkerConfig");`
`35`	`39`	`}`
`@@ -44,7 +48,7 @@ public void Configure(LanguageWorkerOptions options)`
`44`	`48`	`return;`
`45`	`49`	`}`
`46`	`50`
`47`		`- var configFactory = new RpcWorkerConfigFactory(_configuration, _logger, SystemRuntimeInformation.Instance, _environment, _metricsLogger);`
	`51`	`+ var configFactory = new RpcWorkerConfigFactory(_configuration, _logger, SystemRuntimeInformation.Instance, _environment, _metricsLogger, _workerProfileManager);`
`48`	`52`	`options.WorkerConfigs = configFactory.GetConfigs();`
`49`	`53`	`}`
`50`	`54`	`}`