diff --git a/plugin/src/main/java/org/opensearch/ml/action/models/DeleteModelTransportAction.java b/plugin/src/main/java/org/opensearch/ml/action/models/DeleteModelTransportAction.java index cb31fc9a87..e79ecee40b 100644 --- a/plugin/src/main/java/org/opensearch/ml/action/models/DeleteModelTransportAction.java +++ b/plugin/src/main/java/org/opensearch/ml/action/models/DeleteModelTransportAction.java @@ -352,6 +352,7 @@ private void checkSearchPipelineBeforeDeleteModel(String modelId, ActionListener } private void checkDownstreamTaskBeforeDeleteModel(String modelId, Boolean isHidden, ActionListener actionListener) { + // Now 3 is: 1. Agent 2. Search pipeline 3. ingest pipeline CountDownLatch countDownLatch = new CountDownLatch(3); AtomicBoolean noneBlocked = new AtomicBoolean(true); ConcurrentLinkedQueue errorMessages = new ConcurrentLinkedQueue<>();