recover call stdio

oceanbase · Nov 28, 2024 · 61bb9cf · 61bb9cf
1 parent dbcfd8f
commit 61bb9cf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/common/command.py b/common/command.py
@@ -328,7 +328,7 @@ def get_obproxy_version(context):
 def get_observer_version_by_sql(context, ob_cluster, stdio=None):
     stdio.verbose("start get_observer_version_by_sql . input: {0}:{1}".format(ob_cluster.get("db_host"), ob_cluster.get("db_port")))
     try:
-        ob_connector = OBConnector(context=context, ip=ob_cluster.get("db_host"), port=ob_cluster.get("db_port"), username=ob_cluster.get("tenant_sys").get("user"), password=ob_cluster.get("tenant_sys").get("password"), timeout=100)
+        ob_connector = OBConnector(context=context, ip=ob_cluster.get("db_host"), port=ob_cluster.get("db_port"), username=ob_cluster.get("tenant_sys").get("user"), password=ob_cluster.get("tenant_sys").get("password"), stdio=stdio, timeout=100)
         ob_version_info = ob_connector.execute_sql("select version();")
     except Exception as e:
         raise Exception("get_observer_version_by_sql Exception. Maybe cluster'info is error: " + e.__str__())