From cde393435990c03dca32a5d35052385ce95516c0 Mon Sep 17 00:00:00 2001 From: xinyual Date: Mon, 25 Nov 2024 10:40:17 +0800 Subject: [PATCH] apply comment Signed-off-by: xinyual --- .../opensearch/ml/action/models/DeleteModelTransportAction.java | 1 + 1 file changed, 1 insertion(+) 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<>();