apply comment

xinyual · xinyual · commit cde393435990 · 2024-11-25T10:40:17.000+08:00
Signed-off-by: xinyual &lt;xinyual@amazon.com&gt;
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
@@ -352,6 +352,7 @@ private void checkSearchPipelineBeforeDeleteModel(String modelId, ActionListener
     }
 
     private void checkDownstreamTaskBeforeDeleteModel(String modelId, Boolean isHidden, ActionListener<DeleteResponse> actionListener) {
+        // Now 3 is: 1. Agent 2. Search pipeline 3. ingest pipeline
         CountDownLatch countDownLatch = new CountDownLatch(3);
         AtomicBoolean noneBlocked = new AtomicBoolean(true);
         ConcurrentLinkedQueue<String> errorMessages = new ConcurrentLinkedQueue<>();

Original file line number	Diff line number	Diff line change
`@@ -352,6 +352,7 @@ private void checkSearchPipelineBeforeDeleteModel(String modelId, ActionListener`
`352`	`352`	`}`
`353`	`353`
`354`	`354`	`private void checkDownstreamTaskBeforeDeleteModel(String modelId, Boolean isHidden, ActionListener<DeleteResponse> actionListener) {`
	`355`	`+ // Now 3 is: 1. Agent 2. Search pipeline 3. ingest pipeline`
`355`	`356`	`CountDownLatch countDownLatch = new CountDownLatch(3);`
`356`	`357`	`AtomicBoolean noneBlocked = new AtomicBoolean(true);`
`357`	`358`	`ConcurrentLinkedQueue<String> errorMessages = new ConcurrentLinkedQueue<>();`