fixed: analyze queue/memory get obversion (#712)

* Rename Dockerfile to DockerFile * Handling Multi-Version Compatibility Scenarios * Handling Multi-Version Compatibility Scenarios * Handling Multi-Version Compatibility Gather Scenarios * fixed: display function * fixed: display function * 3.1.0 release * fixed: [analyze memory] get obversion * fixed: [analyze queue] get obversion
oceanbase · Jan 23, 2025 · 3a4bf65 · 3a4bf65
1 parent 8e76501
commit 3a4bf65
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/handler/analyzer/analyze_memory.py b/src/handler/analyzer/analyze_memory.py
@@ -23,7 +23,7 @@
 import tabulate
 import threading
 import uuid
-from src.common.command import get_observer_version_by_sql
+from src.common.command import get_observer_version
 from src.common.tool import DirectoryUtil, TimeUtils, Util, NetUtils, FileUtil
 from src.common.obdiag_exception import OBDIAGFormatException
 from src.common.constant import const
@@ -130,7 +130,7 @@ def init_option(self):
     def get_version(self):
         observer_version = ""
         try:
-            observer_version = get_observer_version_by_sql(self.context, self.ob_cluster)
+            observer_version = get_observer_version(self.context)
         except Exception as e:
             self.stdio.exception("failed to get observer version:{0}".format(e))
         self.stdio.verbose("get observer version: {0}".format(observer_version))

diff --git a/src/handler/analyzer/analyze_queue.py b/src/handler/analyzer/analyze_queue.py
@@ -19,7 +19,7 @@
 import os
 import csv
 from tabulate import tabulate
-from src.common.command import get_observer_version_by_sql
+from src.common.command import get_observer_version
 from src.common.ssh_client.local_client import LocalClient
 from src.handler.base_shell_handler import BaseShellHandler
 from src.common.obdiag_exception import OBDIAGFormatException, OBDIAGDBConnException
@@ -157,7 +157,7 @@ def init_option(self):
     def get_version(self):
         observer_version = ""
         try:
-            observer_version = get_observer_version_by_sql(self.context, self.ob_cluster)
+            observer_version = get_observer_version(self.context)
         except Exception as e:
             self.stdio.warn("AnalyzeQueueHandler failed to get observer version:{0}".format(e))
         self.stdio.verbose("AnalyzeQueueHandler get observer version: {0}".format(observer_version))