mirror of
https://github.com/honeymoose/OpenSearch.git
synced 2025-02-08 22:14:59 +00:00
The system created and models we provide now use the `_xpack` user for uniformity with our other features The `PUT` action is now an admin cluster action And XPackClient class now references the action instance.
This commit is contained in:
parent
4e837599b3
commit
eb8fd44836
@ -25,7 +25,7 @@ import java.util.Objects;
|
|||||||
public class PutTrainedModelAction extends ActionType<PutTrainedModelAction.Response> {
|
public class PutTrainedModelAction extends ActionType<PutTrainedModelAction.Response> {
|
||||||
|
|
||||||
public static final PutTrainedModelAction INSTANCE = new PutTrainedModelAction();
|
public static final PutTrainedModelAction INSTANCE = new PutTrainedModelAction();
|
||||||
public static final String NAME = "cluster:monitor/xpack/ml/inference/put";
|
public static final String NAME = "cluster:admin/xpack/ml/inference/put";
|
||||||
private PutTrainedModelAction() {
|
private PutTrainedModelAction() {
|
||||||
super(NAME, Response::new);
|
super(NAME, Response::new);
|
||||||
}
|
}
|
||||||
|
@ -22,6 +22,7 @@ import org.elasticsearch.xpack.core.ml.inference.TrainedModelConfig;
|
|||||||
import org.elasticsearch.xpack.core.ml.inference.TrainedModelDefinition;
|
import org.elasticsearch.xpack.core.ml.inference.TrainedModelDefinition;
|
||||||
import org.elasticsearch.xpack.core.ml.inference.TrainedModelInput;
|
import org.elasticsearch.xpack.core.ml.inference.TrainedModelInput;
|
||||||
import org.elasticsearch.xpack.core.ml.utils.ExceptionsHelper;
|
import org.elasticsearch.xpack.core.ml.utils.ExceptionsHelper;
|
||||||
|
import org.elasticsearch.xpack.core.security.user.XPackUser;
|
||||||
import org.elasticsearch.xpack.ml.dataframe.DataFrameAnalyticsTask.ProgressTracker;
|
import org.elasticsearch.xpack.ml.dataframe.DataFrameAnalyticsTask.ProgressTracker;
|
||||||
import org.elasticsearch.xpack.ml.dataframe.process.results.AnalyticsResult;
|
import org.elasticsearch.xpack.ml.dataframe.process.results.AnalyticsResult;
|
||||||
import org.elasticsearch.xpack.ml.dataframe.process.results.RowResults;
|
import org.elasticsearch.xpack.ml.dataframe.process.results.RowResults;
|
||||||
@ -173,7 +174,7 @@ public class AnalyticsResultProcessor {
|
|||||||
.collect(toList());
|
.collect(toList());
|
||||||
return TrainedModelConfig.builder()
|
return TrainedModelConfig.builder()
|
||||||
.setModelId(modelId)
|
.setModelId(modelId)
|
||||||
.setCreatedBy("data-frame-analytics")
|
.setCreatedBy(XPackUser.NAME)
|
||||||
.setVersion(Version.CURRENT)
|
.setVersion(Version.CURRENT)
|
||||||
.setCreateTime(createTime)
|
.setCreateTime(createTime)
|
||||||
.setTags(Collections.singletonList(analytics.getId()))
|
.setTags(Collections.singletonList(analytics.getId()))
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"model_id" : "lang_ident_model_1",
|
"model_id" : "lang_ident_model_1",
|
||||||
"created_by" : "ml_admin",
|
"created_by" : "_xpack",
|
||||||
"version" : "7.6.0",
|
"version" : "7.6.0",
|
||||||
"description" : "Model used for identifying language from arbitrary input text.",
|
"description" : "Model used for identifying language from arbitrary input text.",
|
||||||
"create_time" : 1575548914594,
|
"create_time" : 1575548914594,
|
||||||
|
@ -20,6 +20,7 @@ import org.elasticsearch.xpack.core.ml.dataframe.analyses.Regression;
|
|||||||
import org.elasticsearch.xpack.core.ml.inference.TrainedModelConfig;
|
import org.elasticsearch.xpack.core.ml.inference.TrainedModelConfig;
|
||||||
import org.elasticsearch.xpack.core.ml.inference.TrainedModelDefinition;
|
import org.elasticsearch.xpack.core.ml.inference.TrainedModelDefinition;
|
||||||
import org.elasticsearch.xpack.core.ml.inference.TrainedModelDefinitionTests;
|
import org.elasticsearch.xpack.core.ml.inference.TrainedModelDefinitionTests;
|
||||||
|
import org.elasticsearch.xpack.core.security.user.XPackUser;
|
||||||
import org.elasticsearch.xpack.ml.dataframe.DataFrameAnalyticsTask.ProgressTracker;
|
import org.elasticsearch.xpack.ml.dataframe.DataFrameAnalyticsTask.ProgressTracker;
|
||||||
import org.elasticsearch.xpack.ml.dataframe.process.results.AnalyticsResult;
|
import org.elasticsearch.xpack.ml.dataframe.process.results.AnalyticsResult;
|
||||||
import org.elasticsearch.xpack.ml.dataframe.process.results.RowResults;
|
import org.elasticsearch.xpack.ml.dataframe.process.results.RowResults;
|
||||||
@ -167,7 +168,7 @@ public class AnalyticsResultProcessorTests extends ESTestCase {
|
|||||||
assertThat(storedModel.getLicenseLevel(), equalTo(License.OperationMode.PLATINUM));
|
assertThat(storedModel.getLicenseLevel(), equalTo(License.OperationMode.PLATINUM));
|
||||||
assertThat(storedModel.getModelId(), containsString(JOB_ID));
|
assertThat(storedModel.getModelId(), containsString(JOB_ID));
|
||||||
assertThat(storedModel.getVersion(), equalTo(Version.CURRENT));
|
assertThat(storedModel.getVersion(), equalTo(Version.CURRENT));
|
||||||
assertThat(storedModel.getCreatedBy(), equalTo("data-frame-analytics"));
|
assertThat(storedModel.getCreatedBy(), equalTo(XPackUser.NAME));
|
||||||
assertThat(storedModel.getTags(), contains(JOB_ID));
|
assertThat(storedModel.getTags(), contains(JOB_ID));
|
||||||
assertThat(storedModel.getDescription(), equalTo(JOB_DESCRIPTION));
|
assertThat(storedModel.getDescription(), equalTo(JOB_DESCRIPTION));
|
||||||
assertThat(storedModel.getModelDefinition(), equalTo(inferenceModel.build()));
|
assertThat(storedModel.getModelDefinition(), equalTo(inferenceModel.build()));
|
||||||
|
Loading…
x
Reference in New Issue
Block a user