Fix IT failure

Signed-off-by: b4sjoo <sicheng.song@outlook.com>

Author: b4sjoo

plugin/src/main/java/org/opensearch/ml/model/MLModelManager.java

@@ -132,7 +132,6 @@
 import org.opensearch.ml.engine.indices.MLIndicesHandler;
 import org.opensearch.ml.engine.utils.FileUtils;
 import org.opensearch.ml.profile.MLModelProfile;
-import org.opensearch.ml.settings.MLFeatureEnabledSetting;
 import org.opensearch.ml.stats.ActionName;
 import org.opensearch.ml.stats.MLActionLevelStat;
 import org.opensearch.ml.stats.MLNodeLevelStat;
@@ -180,7 +179,6 @@ public class MLModelManager {
     private final MLTaskManager mlTaskManager;
     private final MLEngine mlEngine;
     private final DiscoveryNodeHelper nodeHelper;
-    private final MLFeatureEnabledSetting mlFeatureEnabledSetting;
 
     private volatile Integer maxModelPerNode;
     private volatile Integer maxRegisterTasksPerNode;
@@ -211,8 +209,7 @@ public MLModelManager(
         MLTaskManager mlTaskManager,
         MLModelCacheHelper modelCacheHelper,
         MLEngine mlEngine,
-        DiscoveryNodeHelper nodeHelper,
-        MLFeatureEnabledSetting mlFeatureEnabledSetting
+        DiscoveryNodeHelper nodeHelper
     ) {
         this.client = client;
         this.sdkClient = sdkClient;
@@ -228,7 +225,6 @@ public MLModelManager(
         this.mlTaskManager = mlTaskManager;
         this.mlEngine = mlEngine;
         this.nodeHelper = nodeHelper;
-        this.mlFeatureEnabledSetting = mlFeatureEnabledSetting;
 
         this.maxModelPerNode = ML_COMMONS_MAX_MODELS_PER_NODE.get(settings);
         clusterService.getClusterSettings().addSettingsUpdateConsumer(ML_COMMONS_MAX_MODELS_PER_NODE, it -> maxModelPerNode = it);
@@ -1334,9 +1330,6 @@ public synchronized void updateModelCache(String modelId, ActionListener<String>
      */
     public synchronized void deployControllerWithDeployedModel(String modelId, ActionListener<String> listener) {
         try (ThreadContext.StoredContext context = client.threadPool().getThreadContext().stashContext()) {
-            if (!mlFeatureEnabledSetting.isControllerEnabled()) {
-                throw new IllegalStateException(CONTROLLER_DISABLED_ERR_MSG);
-            }
             if (!modelCacheHelper.isModelDeployed(modelId)) {
                 throw new OpenSearchStatusException(
                     "The model of this model controller has not deployed yet, please deploy the model first.",
@@ -1506,9 +1499,6 @@ private synchronized void deployControllerWithDeployingModel(
      * @param mlModel ml model
      */
     public void deployControllerWithDeployingModel(MLModel mlModel, Integer eligibleNodeCount) {
-        if (!mlFeatureEnabledSetting.isControllerEnabled()) {
-            throw new IllegalStateException(CONTROLLER_DISABLED_ERR_MSG);
-        }
         if (mlModel.getModelState() != MLModelState.DEPLOYING) {
             throw new OpenSearchStatusException(
                 "This method should only be called when model is in DEPLOYING state, but the model is in state: " + mlModel.getModelState(),

plugin/src/main/java/org/opensearch/ml/plugin/MachineLearningPlugin.java

@@ -511,8 +511,7 @@ public Collection<Object> createComponents(
             mlTaskManager,
             modelCacheHelper,
             mlEngine,
-            nodeHelper,
-            mlFeatureEnabledSetting
+            nodeHelper
         );
         mlInputDatasetHandler = new MLInputDatasetHandler(client);
         modelAccessControlHelper = new ModelAccessControlHelper(clusterService, settings);

plugin/src/test/java/org/opensearch/ml/model/MLModelManagerTests.java

@@ -122,7 +122,6 @@
 import org.opensearch.ml.engine.encryptor.EncryptorImpl;
 import org.opensearch.ml.engine.indices.MLIndicesHandler;
 import org.opensearch.ml.sdkclient.SdkClientFactory;
-import org.opensearch.ml.settings.MLFeatureEnabledSetting;
 import org.opensearch.ml.stats.ActionName;
 import org.opensearch.ml.stats.MLActionLevelStat;
 import org.opensearch.ml.stats.MLNodeLevelStat;
@@ -209,8 +208,6 @@ public class MLModelManagerTests extends OpenSearchTestCase {
 
     @Mock
     private MLTask pretrainedMLTask;
-    @Mock
-    MLFeatureEnabledSetting mlFeatureEnabledSetting;
 
     @Before
     public void setup() throws URISyntaxException, IOException {
@@ -287,7 +284,6 @@ public void setup() throws URISyntaxException, IOException {
         when(client.threadPool()).thenReturn(threadPool);
         when(threadPool.getThreadContext()).thenReturn(threadContext);
         when(threadPool.executor(any())).thenReturn(testThreadPool.executor(GENERAL_THREAD_POOL));
-        when(mlFeatureEnabledSetting.isControllerEnabled()).thenReturn(true);
 
         modelManager = spy(
             new MLModelManager(
@@ -305,8 +301,7 @@ public void setup() throws URISyntaxException, IOException {
                 mlTaskManager,
                 modelCacheHelper,
                 mlEngine,
-                nodeHelper,
-                mlFeatureEnabledSetting
+                nodeHelper
             )
         );