Skip to content

Commit 2406fab

Browse files
committed
rename syncPlanningWorkerNodes from comments
Signed-off-by: Xun Zhang <xunzh@amazon.com>
1 parent 7989a0c commit 2406fab

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

plugin/src/main/java/org/opensearch/ml/model/MLModelCache.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -146,7 +146,7 @@ public void syncWorkerNode(Set<String> workerNodes) {
146146
this.workerNodes.addAll(workerNodes);
147147
}
148148

149-
public void syncPlanningWorkerNode(Set<String> planningWorkerNodes) {
149+
public void syncPlanningWorkerNodes(Set<String> planningWorkerNodes) {
150150
this.targetWorkerNodes.clear();
151151
this.targetWorkerNodes.addAll(planningWorkerNodes);
152152
}

plugin/src/main/java/org/opensearch/ml/model/MLModelCacheHelper.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -632,7 +632,7 @@ public void syncPlanningWorkerNodes(Map<String, Set<String>> modelPlanningWorker
632632
log.debug("sync model planning worker nodes");
633633
modelPlanningWorkerNodes.entrySet().forEach(entry -> {
634634
MLModelCache modelCache = getOrCreateModelCache(entry.getKey());
635-
modelCache.syncPlanningWorkerNode(entry.getValue());
635+
modelCache.syncPlanningWorkerNodes(entry.getValue());
636636
});
637637
}
638638

0 commit comments

Comments
 (0)