Function start_worker_process

internbootcamp/utils/tool_server/cli.py:99–144

在子进程中启动Worker服务器

(tools_config, host, port, worker_id, master_url, log_file=None)

def start_worker_process(tools_config, host, port, worker_id, master_url, log_file=None):
    """在子进程中启动Worker服务器"""
    # 设置无缓冲输出
    sys.stdout.reconfigure(line_buffering=True) if hasattr(sys.stdout, 'reconfigure') else None
    sys.stderr.reconfigure(line_buffering=True) if hasattr(sys.stderr, 'reconfigure') else None
    
    # 重定向输出到日志文件（如果指定）
    if log_file:
        redirect_output_to_log(log_file, f"Worker-{worker_id}")
    else:
        # 如果没有指定日志文件，创建一个临时日志文件
        temp_log_file = f"/tmp/worker_{worker_id}.log"
        try:
            # 确保日志目录存在
            os.makedirs(os.path.dirname(temp_log_file), exist_ok=True)
            # 创建日志文件
            with open(temp_log_file, 'w') as f:
                timestamp = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
                f.write(f"[{timestamp}] Worker {worker_id} 子进程启动\n")
            
            # 重定向到该日志文件，同时输出到控制台
            class TeeOutput:
                def __init__(self, *files):
                    self.files = files

                def write(self, data):
                    if data:
                        data = sanitize_log_message(data)
                        for f in self.files:
                            f.write(data)
                            f.flush()

                def flush(self):
                    for f in self.files:
                        f.flush()
            
            log_file_obj = open(temp_log_file, 'a', buffering=1)  # 行缓冲
            sys.stdout = TeeOutput(sys.__stdout__, log_file_obj)
            sys.stderr = TeeOutput(sys.__stderr__, log_file_obj)
            
            print(f"📝 Worker {worker_id} 日志: {temp_log_file}")
        except Exception as e:
            print(f"⚠️  无法创建日志文件 {temp_log_file}: {e}")
    
    worker = DistributedWorkerServer(tools_config, host, port, worker_id, master_url, log_file=log_file)
    worker.run()


def create_merged_yaml_from_bootcamp_registry(bootcamp_registry_path, output_yaml_path):