Track down failure given that it OOMs the test harness

droberts195 · Mar 19, 2024 · ae2cb66 · ae2cb66
1 parent d093fb3
commit ae2cb66
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/...in/ml/src/main/java/org/elasticsearch/xpack/ml/utils/InferenceProcessorInfoExtractor.java b/...in/ml/src/main/java/org/elasticsearch/xpack/ml/utils/InferenceProcessorInfoExtractor.java
@@ -13,6 +13,7 @@
 import org.elasticsearch.ingest.ConfigurationUtils;
 import org.elasticsearch.ingest.IngestMetadata;
 import org.elasticsearch.ingest.Pipeline;
+import org.elasticsearch.logging.LogManager;
 import org.elasticsearch.transport.Transports;
 
 import java.util.HashMap;
@@ -76,7 +77,11 @@ public static int countInferenceProcessors(ClusterState state) {
      */
     @SuppressWarnings("unchecked")
     public static Map<String, Set<String>> pipelineIdsByResource(ClusterState state, Set<String> ids) {
-        assert Transports.assertNotTransportThread("non-trivial nested loops over cluster state structures");
+        try {
+            assert Transports.assertNotTransportThread("non-trivial nested loops over cluster state structures");
+        } catch (AssertionError e) {
+            LogManager.getLogger(InferenceProcessorInfoExtractor.class).fatal("should not be here", e);
+        }
         Map<String, Set<String>> pipelineIdsByModelIds = new HashMap<>();
         Metadata metadata = state.metadata();
         if (metadata == null) {