Skip to content

Commit feacbed

Browse files
[7.3][ML] Stop df-analytics action request should filter tasks (#44016) (#44024)
As a `BaseTasksRequest`, `StopDataFrameAnalyticsAction.Request` should implement a `match` method that makes sure only df-analytics tasks are applied.
1 parent 12fb0b6 commit feacbed

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/action/StopDataFrameAnalyticsAction.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@
2222
import org.elasticsearch.common.xcontent.ToXContentObject;
2323
import org.elasticsearch.common.xcontent.XContentBuilder;
2424
import org.elasticsearch.common.xcontent.XContentParser;
25+
import org.elasticsearch.tasks.Task;
2526
import org.elasticsearch.xpack.core.ml.dataframe.DataFrameAnalyticsConfig;
2627
import org.elasticsearch.xpack.core.ml.job.messages.Messages;
2728
import org.elasticsearch.xpack.core.ml.utils.ExceptionsHelper;
@@ -125,6 +126,11 @@ public void setExpandedIds(Set<String> expandedIds) {
125126
this.expandedIds = Objects.requireNonNull(expandedIds);
126127
}
127128

129+
@Override
130+
public boolean match(Task task) {
131+
return expandedIds.stream().anyMatch(expandedId -> StartDataFrameAnalyticsAction.TaskMatcher.match(task, expandedId));
132+
}
133+
128134
@Override
129135
public ActionRequestValidationException validate() {
130136
return null;

0 commit comments

Comments
 (0)