Skip to content

Commit a185042

Browse files
committed
add tests
Signed-off-by: chrislai <[email protected]>
1 parent 514fbd4 commit a185042

File tree

8 files changed

+103
-288
lines changed

8 files changed

+103
-288
lines changed

.java-version

Lines changed: 0 additions & 1 deletion
This file was deleted.

common/src/main/java/org/opensearch/ml/common/settings/MLCommonsSettings.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -353,7 +353,7 @@ private MLCommonsSettings() {}
353353

354354
// Feature flag for enabling telemetry tracer
355355
public static final Setting<Boolean> ML_COMMONS_AGENT_TRACING_FEATURE_ENABLED = Setting
356-
.boolSetting("plugins.ml_commons.agent_tracing_feature_enabled", false, Setting.Property.NodeScope, Setting.Property.Final);
356+
.boolSetting("plugins.ml_commons.agent_tracing_feature_enabled", false, Setting.Property.NodeScope, Setting.Property.Final);
357357

358358
// Feature flag for enabling telemetry agent tracing
359359
public static final Setting<Boolean> ML_COMMONS_AGENT_TRACING_ENABLED = Setting

common/src/main/java/org/opensearch/ml/common/settings/MLFeatureEnabledSetting.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,8 @@
88
package org.opensearch.ml.common.settings;
99

1010
import static org.opensearch.ml.common.settings.MLCommonsSettings.ML_COMMONS_AGENT_FRAMEWORK_ENABLED;
11+
import static org.opensearch.ml.common.settings.MLCommonsSettings.ML_COMMONS_AGENT_TRACING_ENABLED;
12+
import static org.opensearch.ml.common.settings.MLCommonsSettings.ML_COMMONS_AGENT_TRACING_FEATURE_ENABLED;
1113
import static org.opensearch.ml.common.settings.MLCommonsSettings.ML_COMMONS_CONNECTOR_PRIVATE_IP_ENABLED;
1214
import static org.opensearch.ml.common.settings.MLCommonsSettings.ML_COMMONS_CONTROLLER_ENABLED;
1315
import static org.opensearch.ml.common.settings.MLCommonsSettings.ML_COMMONS_LOCAL_MODEL_ENABLED;
@@ -19,8 +21,6 @@
1921
import static org.opensearch.ml.common.settings.MLCommonsSettings.ML_COMMONS_RAG_PIPELINE_FEATURE_ENABLED;
2022
import static org.opensearch.ml.common.settings.MLCommonsSettings.ML_COMMONS_REMOTE_INFERENCE_ENABLED;
2123
import static org.opensearch.ml.common.settings.MLCommonsSettings.ML_COMMONS_STATIC_METRIC_COLLECTION_ENABLED;
22-
import static org.opensearch.ml.common.settings.MLCommonsSettings.ML_COMMONS_AGENT_TRACING_FEATURE_ENABLED;
23-
import static org.opensearch.ml.common.settings.MLCommonsSettings.ML_COMMONS_AGENT_TRACING_ENABLED;
2424

2525
import java.util.ArrayList;
2626
import java.util.List;

common/src/test/java/org/opensearch/ml/common/settings/MLFeatureEnabledSettingTests.java

Lines changed: 11 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,9 @@ public void setUp() {
4343
MLCommonsSettings.ML_COMMONS_MCP_SERVER_ENABLED,
4444
MLCommonsSettings.ML_COMMONS_RAG_PIPELINE_FEATURE_ENABLED,
4545
MLCommonsSettings.ML_COMMONS_METRIC_COLLECTION_ENABLED,
46-
MLCommonsSettings.ML_COMMONS_STATIC_METRIC_COLLECTION_ENABLED
46+
MLCommonsSettings.ML_COMMONS_STATIC_METRIC_COLLECTION_ENABLED,
47+
MLCommonsSettings.ML_COMMONS_AGENT_TRACING_FEATURE_ENABLED,
48+
MLCommonsSettings.ML_COMMONS_AGENT_TRACING_ENABLED
4749
)
4850
);
4951
when(mockClusterService.getClusterSettings()).thenReturn(mockClusterSettings);
@@ -65,6 +67,8 @@ public void testDefaults_allFeaturesEnabled() {
6567
.put("plugins.ml_commons.rag_pipeline_feature_enabled", true)
6668
.put("plugins.ml_commons.metrics_collection_enabled", true)
6769
.put("plugins.ml_commons.metrics_static_collection_enabled", true)
70+
.put("plugins.ml_commons.agent_tracing_feature_enabled", true)
71+
.put("plugins.ml_commons.agent_tracing_enabled", true)
6872
.build();
6973

7074
MLFeatureEnabledSetting setting = new MLFeatureEnabledSetting(mockClusterService, settings);
@@ -81,6 +85,8 @@ public void testDefaults_allFeaturesEnabled() {
8185
assertTrue(setting.isRagSearchPipelineEnabled());
8286
assertTrue(setting.isMetricCollectionEnabled());
8387
assertTrue(setting.isStaticMetricCollectionEnabled());
88+
assertTrue(setting.isAgentTracingFeatureEnabled());
89+
assertTrue(setting.isAgentTracingEnabled());
8490
}
8591

8692
@Test
@@ -99,6 +105,8 @@ public void testDefaults_someFeaturesDisabled() {
99105
.put("plugins.ml_commons.rag_pipeline_feature_enabled", false)
100106
.put("plugins.ml_commons.metrics_collection_enabled", false)
101107
.put("plugins.ml_commons.metrics_static_collection_enabled", false)
108+
.put("plugins.ml_commons.agent_tracing_feature_enabled", false)
109+
.put("plugins.ml_commons.agent_tracing_enabled", false)
102110
.build();
103111

104112
MLFeatureEnabledSetting setting = new MLFeatureEnabledSetting(mockClusterService, settings);
@@ -115,6 +123,8 @@ public void testDefaults_someFeaturesDisabled() {
115123
assertFalse(setting.isRagSearchPipelineEnabled());
116124
assertFalse(setting.isMetricCollectionEnabled());
117125
assertFalse(setting.isStaticMetricCollectionEnabled());
126+
assertFalse(setting.isAgentTracingFeatureEnabled());
127+
assertFalse(setting.isAgentTracingEnabled());
118128
}
119129

120130
@Test

docker-compose.yml

Lines changed: 0 additions & 282 deletions
This file was deleted.

ml-algorithms/src/main/java/org/opensearch/ml/engine/algorithms/agent/tracing/MLAgentTracer.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -106,4 +106,8 @@ public void endSpan(Span span) {
106106
public Tracer getTracer() {
107107
return tracer;
108108
}
109+
110+
static void resetForTest() {
111+
instance = null;
112+
}
109113
}

0 commit comments

Comments
 (0)