improve comments and log message

Author: ntudy

docs/e2b.Dockerfile

@@ -149,7 +149,7 @@ RUN python3 -m pip install --no-cache-dir \
 
 RUN apt-get update && \
     apt-get install -y --no-install-recommends \
-    # ── 基础构建 & Python ───────────────────────────────
+    # ── Basic build & Python ───────────────────────────────
     build-essential gfortran cmake pkg-config git curl wget ca-certificates \
     # ── scientific computing ───────────────────────────────────────
     libopenblas-dev liblapack-dev libatlas-base-dev \

libs/miroflow-tool/src/miroflow/tool/README.md

@@ -108,7 +108,7 @@ Add your tool configuration to `mirage/apps/reorg-modular-structure/src/mirage_a
 
 ```python
 def create_mcp_server_parameters(cfg: DictConfig, agent_cfg: DictConfig):
-    """定义并返回 MCP 服务器配置列表"""
+    """Define and return MCP server configuration list"""
     configs = []
 
     # ... existing code ...

libs/miroflow-tool/src/miroflow/tool/manager.py

@@ -6,7 +6,7 @@
 import functools
 from typing import Any, Awaitable, Callable, Protocol, TypeVar
 
-from mcp import ClientSession, StdioServerParameters  # (已在 config.py 导入)
+from mcp import ClientSession, StdioServerParameters  # (already imported in config.py)
 from mcp.client.sse import sse_client
 from mcp.client.stdio import stdio_client
 
@@ -138,7 +138,7 @@ async def _find_servers_with_tool(self, tool_name):
                                     break
                 else:
                     logger.error(
-                        f"错误: 服务器 '{server_name}' 的参数类型未知: {type(server_params)}"
+                        f"Error: Unknown parameter type for server '{server_name}': {type(server_params)}"
                     )
                     # For unknown types, we skip rather than throw an exception, because this is a search function
                     continue
@@ -208,7 +208,7 @@ async def get_all_tool_definitions(self):
                                 )
                 else:
                     logger.error(
-                        f"错误: 服务器 '{server_name}' 的参数类型未知: {type(server_params)}"
+                        f"Error: Unknown parameter type for server '{server_name}': {type(server_params)}"
                     )
                     raise TypeError(
                         f"Unknown server params type for {server_name}: {type(server_params)}"
@@ -239,18 +239,18 @@ async def execute_tool_call(self, server_name, tool_name, arguments) -> Any:
         :return: Dictionary containing result or error
         """
 
-        # 原远程服务器调用逻辑
+        # Original remote server call logic
         server_params = self.get_server_params(server_name)
         if not server_params:
-            logger.error(f"错误: 尝试调用未找到的服务器 '{server_name}'")
+            logger.error(f"Error: Attempting to call server '{server_name}' that was not found")
             return {
                 "server_name": server_name,
                 "tool_name": tool_name,
                 "error": f"Server '{server_name}' not found.",
             }
 
         logger.info(
-            f"正在连接到服务器 '{server_name}' 以调用工具 '{tool_name}'...调用参数为'{arguments}'..."
+            f"Connecting to server '{server_name}' to call tool '{tool_name}'...call arguments: '{arguments}'..."
         )
 
         if server_name == "playwright":
@@ -262,10 +262,10 @@ async def execute_tool_call(self, server_name, tool_name, arguments) -> Any:
                     tool_name, arguments=arguments
                 )
 
-                # 检查结果是否为空并提供更好的反馈
+                # Check if result is empty and provide better feedback
                 if tool_result is None or tool_result == "":
                     logger.error(
-                        f"工具 '{tool_name}' 返回了空结果，可能是正常的（如删除操作）或工具执行有问题"
+                        f"Tool '{tool_name}' returned empty result, this may be normal (such as delete operations) or the tool execution may have issues"
                     )
                     return {
                         "server_name": server_name,
@@ -297,23 +297,23 @@ async def execute_tool_call(self, server_name, tool_name, arguments) -> Any:
                                 tool_result = await session.call_tool(
                                     tool_name, arguments=arguments
                                 )
-                                # 安全地提取结果内容，不改变原始格式
+                                # Safely extract result content without changing original format
                                 if tool_result.content and len(tool_result.content) > 0:
                                     text_content = tool_result.content[-1].text
                                     if (
                                         text_content is not None
                                         and text_content.strip()
                                     ):
-                                        result_content = text_content  # 保留原始格式！
+                                        result_content = text_content  # Preserve original format!
                                     else:
                                         result_content = f"Tool '{tool_name}' completed but returned empty text - this may be expected or indicate an issue"
                                 else:
                                     result_content = f"Tool '{tool_name}' completed but returned no content - this may be expected or indicate an issue"
 
-                                # 如果结果为空，记录警告
+                                # If result is empty, log warning
                                 if not tool_result.content:
                                     logger.error(
-                                        f"工具 '{tool_name}' 返回了空内容，tool_result.content: {tool_result.content}"
+                                        f"Tool '{tool_name}' returned empty content, tool_result.content: {tool_result.content}"
                                     )
 
                                 # post hoc check for browsing agent reading answers from hf datsets
@@ -338,23 +338,23 @@ async def execute_tool_call(self, server_name, tool_name, arguments) -> Any:
                                 tool_result = await session.call_tool(
                                     tool_name, arguments=arguments
                                 )
-                                # 安全地提取结果内容，不改变原始格式
+                                # Safely extract result content without changing original format
                                 if tool_result.content and len(tool_result.content) > 0:
                                     text_content = tool_result.content[-1].text
                                     if (
                                         text_content is not None
                                         and text_content.strip()
                                     ):
-                                        result_content = text_content  # 保留原始格式！
+                                        result_content = text_content  # Preserve original format!
                                     else:
                                         result_content = f"Tool '{tool_name}' completed but returned empty text - this may be expected or indicate an issue"
                                 else:
                                     result_content = f"Tool '{tool_name}' completed but returned no content - this may be expected or indicate an issue"
 
-                                # 如果结果为空，记录警告
+                                # If result is empty, log warning
                                 if not tool_result.content:
                                     logger.error(
-                                        f"工具 '{tool_name}' 返回了空内容，tool_result.content: {tool_result.content}"
+                                        f"Tool '{tool_name}' returned empty content, tool_result.content: {tool_result.content}"
                                     )
 
                                 # post hoc check for browsing agent reading answers from hf datsets
@@ -372,20 +372,20 @@ async def execute_tool_call(self, server_name, tool_name, arguments) -> Any:
                         f"Unknown server params type for {server_name}: {type(server_params)}"
                     )
 
-                logger.info(f"工具 '{tool_name}' (服务器: '{server_name}') 调用成功。")
+                logger.info(f"Tool '{tool_name}' (server: '{server_name}') called successfully.")
 
                 return {
                     "server_name": server_name,
                     "tool_name": tool_name,
-                    "result": result_content,  # 返回提取的文本内容
+                    "result": result_content,  # Return extracted text content
                 }
 
             except Exception as outer_e:  # Rename this to outer_e to avoid shadowing
                 logger.error(
-                    f"错误: 调用工具 '{tool_name}' (服务器: '{server_name}') 失败: {outer_e}"
+                    f"Error: Failed to call tool '{tool_name}' (server: '{server_name}'): {outer_e}"
                 )
                 # import traceback
-                # traceback.print_exc() # 打印详细堆栈跟踪以进行调试
+                # traceback.print_exc() # Print detailed stack trace for debugging
 
                 # Store the original error message for later use
                 error_message = str(outer_e)
@@ -397,18 +397,18 @@ async def execute_tool_call(self, server_name, tool_name, arguments) -> Any:
                     and arguments["url"] is not None
                 ):
                     try:
-                        logger.info("尝试使用 MarkItDown 进行回退...")
+                        logger.info("Attempting to use MarkItDown for fallback...")
                         from markitdown import MarkItDown
 
                         md = MarkItDown(
                             docintel_endpoint="<document_intelligence_endpoint>"
                         )
                         result = md.convert(arguments["url"])
-                        logger.info("使用 MarkItDown 成功")
+                        logger.info("Successfully used MarkItDown")
                         return {
                             "server_name": server_name,
                             "tool_name": tool_name,
-                            "result": result.text_content,  # 返回提取的文本内容
+                            "result": result.text_content,  # Return extracted text content
                         }
                     except (
                         Exception

libs/miroflow/src/miroflow/llm/providers/claude_openrouter_client.py

@@ -226,7 +226,7 @@ async def _create_message(
                 raise ContextLimitError(f"Context limit exceeded: {error_str}")
 
             logger.error(
-                f"OpenRouter LLM 调用失败: {str(e)}, input = {json.dumps(params)}",
+                f"OpenRouter LLM call failed: {str(e)}, input = {json.dumps(params)}",
                 exc_info=True,
             )
             raise e

libs/miroflow/src/miroflow/prebuilt/orchestrator.py

@@ -547,7 +547,7 @@ async def run_sub_agent(
             # Generate summary_prompt to check token limit
             temp_summary_prompt = generate_agent_summarize_prompt(
                 task_description,
-                task_failed=True,  # 这里设为True，模拟可能的任务失败情况进行context检查
+                task_failed=True,  # Set to True here to simulate potential task failure for context checking
                 agent_type=sub_agent_name,
             )
 
@@ -556,7 +556,7 @@ async def run_sub_agent(
                 message_history, temp_summary_prompt
             ):
                 # Context estimated to exceed limit, jump to summary stage
-                task_failed = True  # 标记任务失败
+                task_failed = True  # Mark task as failed
                 self.task_log.log_step(
                     f"{sub_agent_name}_context_limit_reached",
                     "Context limit reached, triggering summary",