Skip to content

Commit 10cb533

Browse files
committed
Respect dynamic setting ML model repo
1 parent 3cc62d3 commit 10cb533

File tree

1 file changed

+1
-5
lines changed

1 file changed

+1
-5
lines changed

x-pack/plugin/ml-package-loader/src/main/java/org/elasticsearch/xpack/ml/packageloader/action/TransportGetTrainedModelPackageConfigAction.java

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,6 @@
1919
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
2020
import org.elasticsearch.cluster.service.ClusterService;
2121
import org.elasticsearch.common.Strings;
22-
import org.elasticsearch.common.settings.Settings;
2322
import org.elasticsearch.common.util.concurrent.EsExecutors;
2423
import org.elasticsearch.injection.guice.Inject;
2524
import org.elasticsearch.rest.RestStatus;
@@ -45,11 +44,9 @@
4544
public class TransportGetTrainedModelPackageConfigAction extends TransportMasterNodeAction<Request, Response> {
4645

4746
private static final Logger logger = LogManager.getLogger(TransportGetTrainedModelPackageConfigAction.class);
48-
private final Settings settings;
4947

5048
@Inject
5149
public TransportGetTrainedModelPackageConfigAction(
52-
Settings settings,
5350
TransportService transportService,
5451
ClusterService clusterService,
5552
ThreadPool threadPool,
@@ -67,12 +64,11 @@ public TransportGetTrainedModelPackageConfigAction(
6764
GetTrainedModelPackageConfigAction.Response::new,
6865
EsExecutors.DIRECT_EXECUTOR_SERVICE
6966
);
70-
this.settings = settings;
7167
}
7268

7369
@Override
7470
protected void masterOperation(Task task, Request request, ClusterState state, ActionListener<Response> listener) throws Exception {
75-
String repository = MachineLearningPackageLoader.MODEL_REPOSITORY.get(settings);
71+
String repository = clusterService.getClusterSettings().get(MachineLearningPackageLoader.MODEL_REPOSITORY);
7672

7773
String packagedModelId = request.getPackagedModelId();
7874
logger.debug(() -> format("Fetch package manifest for [%s] from [%s]", packagedModelId, repository));

0 commit comments

Comments
 (0)