support mac

Author: LINxiansheng

_cmd.py

@@ -3076,6 +3076,8 @@ def __init__(self):
         self.parser._add_version_option()
 
 if __name__ == '__main__':
+    import multiprocessing
+    multiprocessing.freeze_support()
     defaultencoding = 'utf-8'
     if sys.getdefaultencoding() != defaultencoding:
         try:

_errno.py

@@ -111,7 +111,7 @@ class InitDirFailedErrorMessage(object):
     PERMISSION_DENIED = ': {path} permission denied .'
 
 
-DOC_LINK = '<DOC_LINK>'
+DOC_LINK = ''
 DOC_LINK_MSG = 'See {}'.format(DOC_LINK if DOC_LINK else "https://www.oceanbase.com/product/ob-deployer/error-codes .")
 
 # generic error code

_plugin.py

@@ -283,7 +283,10 @@ def _new_func(
             namespace_vars.update(kwargs)
             if arg:
                 idx = 0
-                params = list(inspect2.signature(method).parameters.keys())[1:-2]
+                try:
+                    params = list(inspect2.signature(method).parameters.keys())[1:-2]
+                except (ValueError, TypeError):
+                    params = []
                 num = min(len(arg), len(params))
                 while idx < num:
                     key = params[idx]
@@ -871,6 +874,9 @@ def __init__(self, home_path, script_name=None, dev_mode=False, stdio=None):
         super(PyScriptPluginLoader, self).__init__(home_path, dev_mode=dev_mode, stdio=stdio)
 
     def _create_(self, script_name):
+        # Use an explicit namespace dict for exec() because Python 3.12+ (PEP 667)
+        # changed locals() to return a snapshot, so exec() results won't appear in locals().
+        _ns = {}
         exec('''
 class %s(PyScriptPlugin):
 
@@ -890,8 +896,8 @@ def %s(
         repositories, components, clients, cluster_config, cmd,
         options, stdio, *arg, **kwargs):
         pass
-        ''' % (self.PLUGIN_TYPE.value, script_name, script_name, self.PLUGIN_TYPE.value, self.PLUGIN_TYPE.value, script_name))
-        clz = locals()[self.PLUGIN_TYPE.value]
+        ''' % (self.PLUGIN_TYPE.value, script_name, script_name, self.PLUGIN_TYPE.value, self.PLUGIN_TYPE.value, script_name), globals(), _ns)
+        clz = _ns[self.PLUGIN_TYPE.value]
         setattr(sys.modules[__name__], self.PLUGIN_TYPE.value, clz)
         clz.set_plugin_type(self.PLUGIN_TYPE)
         return clz

_stdio.py

@@ -1150,7 +1150,11 @@ def decorated(func):
             is_bond_method = True
             _type = type(func)
             func = func.__func__
-        all_parameters = inspect2.signature(func).parameters
+        try:
+            all_parameters = inspect2.signature(func).parameters
+        except (ValueError, TypeError):
+            # Builtin slot wrappers (e.g. object.__init__) can't be inspected on Python 3.13+
+            return _type(func) if is_bond_method else func
         if "stdio" in all_parameters:
             default_stdio_in_params = all_parameters["stdio"].default
             if not isinstance(default_stdio_in_params, Parameter.empty):

_workflow.py

@@ -218,6 +218,9 @@ def __init__(self, home_path, workflow_name=None, dev_mode=False, stdio=None):
         self.workflow_name = workflow_name
 
     def _create_(self, workflow_name):
+        # Use an explicit namespace dict for exec() because Python 3.12+ (PEP 667)
+        # changed locals() to return a snapshot, so exec() results won't appear in locals().
+        _ns = {}
         exec('''
 class %s(PyScriptPlugin):
 
@@ -237,8 +240,8 @@ def %s(
         repositories, components, clients, cluster_config, cmd,
         options, stdio, *arg, **kwargs):
         pass
-        ''' % (self.PLUGIN_TYPE.value, workflow_name, workflow_name, self.PLUGIN_TYPE.value, self.PLUGIN_TYPE.value, workflow_name))
-        clz = locals()[self.PLUGIN_TYPE.value]
+        ''' % (self.PLUGIN_TYPE.value, workflow_name, workflow_name, self.PLUGIN_TYPE.value, self.PLUGIN_TYPE.value, workflow_name), globals(), _ns)
+        clz = _ns[self.PLUGIN_TYPE.value]
         setattr(sys.modules[__name__], self.PLUGIN_TYPE.value, clz)
         clz.set_plugin_type(self.PLUGIN_TYPE)
         return clz

const.py

@@ -25,13 +25,13 @@
 TELEMETRY_SIG = 'dbe97393a695335d67de91dd4049ba'
 
 # obdeploy version
-VERSION = '<VERSION>'
+VERSION = '2.7.0.1772075418'
 # obdeploy build commit
-REVISION = '<CID>'
+REVISION = '6a52743d6f002984d08b6c2bd58eb95fb7785ef0'
 # obdeploy build branch
-BUILD_BRANCH = '<B_BRANCH>'
+BUILD_BRANCH = 'mac'
 # obdeploy build time
-BUILD_TIME = '<B_TIME>'
+BUILD_TIME = ' 2月 26 2026 11:10:18'
 # obdeploy build plugin list
 BUILD_PLUGIN_LIST = '<B_PLUGIN_LIST>'
 

plugins-requirements3.txt

@@ -4,4 +4,5 @@ bcrypt==4.0.0
 configparser>=5.2.0
 urllib3==2.5.0
 influxdb==5.3.2
+PyYAML>=6.0
 obshell

plugins/general/0.1/install_repo.py

@@ -16,6 +16,7 @@
 from __future__ import absolute_import, division, print_function
 
 import os
+import platform
 import re
 
 from _plugin import InstallPlugin
@@ -158,7 +159,10 @@ def check_lib():
             for file_item in check_file_map.values():
                 if file_item.type == InstallPlugin.FileItemType.BIN:
                     remote_file_path = os.path.join(remote_home_path, file_item.target_path)
-                    ret = client.execute_command('ldd %s' % remote_file_path)
+                    if platform.system() == 'Darwin':
+                        ret = client.execute_command('otool -L %s' % remote_file_path)
+                    else:
+                        ret = client.execute_command('ldd %s' % remote_file_path)
                     libs = re.findall('(/?[\w+\-/]+\.\w+[\.\w]+)[\s\\n]*\=\>[\s\\n]*not found', ret.stdout)
                     if not libs:
                         libs = re.findall('(/?[\w+\-/]+\.\w+[\.\w]+)[\s\\n]*\=\>[\s\\n]*not found', ret.stderr)

plugins/mysqltest/3.1.0/run_test.py

@@ -19,9 +19,10 @@
 import os
 import time
 import shlex
+import platform
 import requests
 import urllib
-from subprocess import Popen, PIPE
+from subprocess import Popen, PIPE, TimeoutExpired
 from copy import deepcopy
 from ssh import LocalClient
 from tool import DirectoryUtil
@@ -380,20 +381,42 @@ def return_true(**kw):
                 LocalClient.execute_command('%s "alter system set _enable_static_typing_engine = %s;select sleep(2);"' % (exec_sql_cmd, opt['_enable_static_typing_engine']), stdio=stdio)
 
         start_time = time.time()
-        cmd = 'timeout %s %s %s' % (case_timeout, mysqltest_bin, str(Arguments(opt)))
+        IS_DARWIN = platform.system() == 'Darwin'
+        if IS_DARWIN:
+            # macOS does not have GNU timeout; use Python subprocess timeout instead
+            cmd = '%s %s' % (mysqltest_bin, str(Arguments(opt)))
+        else:
+            cmd = 'timeout %s %s %s' % (case_timeout, mysqltest_bin, str(Arguments(opt)))
         try:
             stdio.verbose('local execute: %s ' % cmd)
             p = Popen(shlex.split(cmd), env=test_env, stdout=PIPE, stderr=PIPE)
-            output, errput = p.communicate()
-            retcode = p.returncode
-            if retcode == 124:
-                output = ''
-                if 'source_limit' in opt and 'g.buffer' in opt['source_limit']:
-                    errput = "%s secs out of soft limit (%s secs), sql may be hung, please check" % (opt['source_limit']['g.buffer'], case_timeout)
+            if IS_DARWIN:
+                try:
+                    output, errput = p.communicate(timeout=case_timeout)
+                except TimeoutExpired:
+                    p.kill()
+                    output, errput = p.communicate()
+                    retcode = 124  # mimic GNU timeout exit code
+                    output = ''
+                    if 'source_limit' in opt and 'g.buffer' in opt['source_limit']:
+                        errput = "%s secs out of soft limit (%s secs), sql may be hung, please check" % (opt['source_limit']['g.buffer'], case_timeout)
+                    else:
+                        errput = "%s seconds timeout, sql may be hung, please check" % case_timeout
                 else:
-                    errput = "%s seconds timeout, sql may be hung, please check" % case_timeout
-            elif isinstance(errput, bytes):
-                errput = errput.decode(errors='replace')
+                    retcode = p.returncode
+                    if isinstance(errput, bytes):
+                        errput = errput.decode(errors='replace')
+            else:
+                output, errput = p.communicate()
+                retcode = p.returncode
+                if retcode == 124:
+                    output = ''
+                    if 'source_limit' in opt and 'g.buffer' in opt['source_limit']:
+                        errput = "%s secs out of soft limit (%s secs), sql may be hung, please check" % (opt['source_limit']['g.buffer'], case_timeout)
+                    else:
+                        errput = "%s seconds timeout, sql may be hung, please check" % case_timeout
+                elif isinstance(errput, bytes):
+                    errput = errput.decode(errors='replace')
         except Exception as e:
             errput = str(e)
             output = ''

plugins/seekdb/1.0.0/environment_check.py

@@ -15,13 +15,16 @@
 from __future__ import absolute_import, division, print_function
 
 import os
+import platform
 import re
 
 import _errno as err
 from _arch import getBaseArch
 from _rpm import Version
 from tool import get_port_socket_inode, contains_duplicate_nodes
 
+IS_DARWIN = platform.system() == 'Darwin'
+
 
 def environment_check(plugin_context, work_dir_empty_check=True, generate_configs={}, *args, **kwargs):
     cluster_config = plugin_context.cluster_config
@@ -140,7 +143,10 @@ def environment_check(plugin_context, work_dir_empty_check=True, generate_config
 
         basearch = getBaseArch()
         stdio.verbose("basearch: %s" % basearch)
-        if 'x86' in basearch and len(re.findall(r'(^avx\s+)|(\s+avx\s+)|(\s+avx$)', client.execute_command('lscpu | grep avx').stdout)) == 0:
+        if IS_DARWIN:
+            # macOS does not have lscpu; Apple Silicon natively supports atomics and AVX is N/A.
+            stdio.verbose('Skip CPU instruction set check on macOS')
+        elif 'x86' in basearch and len(re.findall(r'(^avx\s+)|(\s+avx\s+)|(\s+avx$)', client.execute_command('lscpu | grep avx').stdout)) == 0:
             if not (Version('4.2.5.6') <= repository.version < Version('4.3.0.0') or Version('4.3.5.4') <= repository.version < Version('4.4.0.0') or Version('4.4.1.0') <= repository.version):
                 critical(server, 'cpu', err.EC_CPU_NOT_SUPPORT_INSTRUCTION_SET.format(server=server, instruction_set='avx'), [err.SUG_CHANGE_SERVER.format()])
         elif ('arm' in basearch or 'aarch' in basearch) and len(re.findall(r'(^atomics\s+)|(\s+atomics\s+)|(\s+atomics$)', client.execute_command('lscpu | grep atomics').stdout)) == 0 and 'nonlse' not in repository.release: