File tree Expand file tree Collapse file tree 2 files changed +6
-5
lines changed
modules/autotagging-commons/common/src/test/java/org/opensearch/rule/action
plugins/workload-management/src/main/java/org/opensearch/plugin/wlm/rule/sync Expand file tree Collapse file tree 2 files changed +6
-5
lines changed Original file line number Diff line number Diff line change 11
11
import org .opensearch .common .io .stream .BytesStreamOutput ;
12
12
import org .opensearch .core .common .io .stream .StreamInput ;
13
13
import org .opensearch .rule .GetRuleRequest ;
14
+ import org .opensearch .rule .autotagging .Attribute ;
15
+ import org .opensearch .rule .autotagging .Rule ;
14
16
import org .opensearch .rule .utils .RuleTestUtils ;
15
17
import org .opensearch .test .OpenSearchTestCase ;
16
18
17
19
import java .io .IOException ;
18
20
import java .util .HashMap ;
19
-
20
- import static org .opensearch .rule .utils .RuleTestUtils .ATTRIBUTE_MAP ;
21
- import static org .opensearch .rule .utils .RuleTestUtils .SEARCH_AFTER ;
22
- import static org .opensearch .rule .utils .RuleTestUtils ._ID_ONE ;
21
+ import java .util .Map ;
22
+ import java .util .Set ;
23
23
24
24
public class GetRuleRequestTests extends OpenSearchTestCase {
25
25
/**
Original file line number Diff line number Diff line change 16
16
import org .opensearch .common .settings .Settings ;
17
17
import org .opensearch .common .unit .TimeValue ;
18
18
import org .opensearch .core .action .ActionListener ;
19
+ import org .opensearch .plugin .wlm .rule .sync .detect .RuleEvent ;
19
20
import org .opensearch .plugin .wlm .rule .sync .detect .RuleEventClassifier ;
20
21
import org .opensearch .rule .GetRuleRequest ;
21
22
import org .opensearch .rule .GetRuleResponse ;
@@ -125,7 +126,7 @@ public void onResponse(GetRuleResponse response) {
125
126
final Set <Rule > newRules = new HashSet <>(response .getRules ().values ());
126
127
ruleEventClassifier .setPreviousRules (lastRunIndexedRules );
127
128
128
- ruleEventClassifier .getRuleEvents (newRules ).forEach (event -> { event . process (); } );
129
+ ruleEventClassifier .getRuleEvents (newRules ).forEach (RuleEvent :: process );
129
130
130
131
lastRunIndexedRules = newRules ;
131
132
}
You can’t perform that action at this time.
0 commit comments