style: format code with ruff

- Fix line length and whitespace issues
- Remove trailing whitespace from JavaScript files
- Ensure consistent code formatting across the project

Author: liuzhongyu-eagle

docs/scripts/translate_docs.py

@@ -266,7 +266,9 @@ def translate_single_source_file(file_path: str) -> None:
 
 def main():
     parser = argparse.ArgumentParser(description="Translate documentation files")
-    parser.add_argument("--file", type=str, help="Specific file to translate (relative to docs directory)")
+    parser.add_argument(
+        "--file", type=str, help="Specific file to translate (relative to docs directory)"
+    )
     args = parser.parse_args()
 
     if args.file:

examples/basic/hello_world_jupyter.ipynb

@@ -30,7 +30,7 @@
     "agent = Agent(name=\"Assistant\", instructions=\"You are a helpful assistant\")\n",
     "\n",
     "# Intended for Jupyter notebooks where there's an existing event loop\n",
-    "result = await Runner.run(agent, \"Write a haiku about recursion in programming.\") # type: ignore[top-level-await]  # noqa: F704\n",
+    "result = await Runner.run(agent, \"Write a haiku about recursion in programming.\")  # type: ignore[top-level-await]  # noqa: F704\n",
     "print(result.final_output)"
    ]
   }

examples/basic/streaming_tool_basic.py

@@ -13,6 +13,7 @@
 - yield "字符串" 用于最终结果
 - 内部 agent 事件被自动包装为 StreamingToolContextEvent，实现上下文隔离
 """
+
 import asyncio
 from collections.abc import AsyncGenerator
 from typing import Any, TypedDict
@@ -23,6 +24,7 @@
 
 class DemoConfig(TypedDict):
     """演示配置的类型定义"""
+
     name: str
     tool: StreamingTool
     params: str
@@ -33,6 +35,7 @@ class DemoConfig(TypedDict):
 # 示例1：最简单的流式工具
 # ============================================================================
 
+
 @streaming_tool
 async def simple_progress_tool(task_name: str) -> AsyncGenerator[StreamEvent | str, Any]:
     """最基础的流式工具示例
@@ -66,6 +69,7 @@ async def simple_progress_tool(task_name: str) -> AsyncGenerator[StreamEvent | s
 # 示例2：实时倒计时工具
 # ============================================================================
 
+
 @streaming_tool
 async def countdown_tool(seconds: int) -> AsyncGenerator[StreamEvent | str, Any]:
     """倒计时工具 - 演示实时更新和标签使用
@@ -97,6 +101,7 @@ async def countdown_tool(seconds: int) -> AsyncGenerator[StreamEvent | str, Any]
 # 示例3：错误处理演示
 # ============================================================================
 
+
 @streaming_tool
 async def error_demo_tool(should_fail: bool) -> AsyncGenerator[StreamEvent | str, Any]:
     """错误处理演示工具
@@ -134,6 +139,7 @@ async def error_demo_tool(should_fail: bool) -> AsyncGenerator[StreamEvent | str
 # Agent配置
 # ============================================================================
 
+
 def create_basic_demo_agent():
     """创建基础演示Agent"""
     return Agent(
@@ -153,6 +159,7 @@ def create_basic_demo_agent():
 # 演示函数
 # ============================================================================
 
+
 async def demo_basic_concepts():
     """演示@streaming_tool的基础概念"""
     print("=" * 70)
@@ -164,33 +171,34 @@ async def demo_basic_concepts():
     print("\n说明：本演示直接调用流式工具，展示核心概念，无需配置LLM模型")
 
     from agents.run_context import RunContextWrapper
+
     ctx = RunContextWrapper(context=None)
 
     demos: list[DemoConfig] = [
         {
             "name": "基础进度更新",
             "tool": simple_progress_tool,
             "params": '{"task_name": "数据备份"}',
-            "description": "演示最基本的多步骤进度通知"
+            "description": "演示最基本的多步骤进度通知",
         },
         {
             "name": "实时倒计时",
             "tool": countdown_tool,
             "params": '{"seconds": 3}',
-            "description": "演示实时更新和事件标签的使用"
+            "description": "演示实时更新和事件标签的使用",
         },
         {
             "name": "错误处理（成功案例）",
             "tool": error_demo_tool,
             "params": '{"should_fail": false}',
-            "description": "演示正常执行流程"
+            "description": "演示正常执行流程",
         },
         {
             "name": "错误处理（失败案例）",
             "tool": error_demo_tool,
             "params": '{"should_fail": true}',
-            "description": "演示异常处理机制"
-        }
+            "description": "演示异常处理机制",
+        },
     ]
 
     for i, demo in enumerate(demos, 1):
@@ -203,7 +211,7 @@ async def demo_basic_concepts():
 
         event_count = 0
         try:
-            async for event in demo['tool'].on_invoke_tool(ctx, demo['params'], f"demo_{i}"):
+            async for event in demo["tool"].on_invoke_tool(ctx, demo["params"], f"demo_{i}"):
                 event_count += 1
 
                 if isinstance(event, NotifyStreamEvent):
@@ -223,7 +231,7 @@ async def demo_basic_concepts():
                 elif isinstance(event, str):
                     print(f"  [{event_count:2d}] 🎯 最终结果: {event}")
         except Exception as e:
-            print(f"  [{event_count+1:2d}] ❌ 工具执行异常: {e}")
+            print(f"  [{event_count + 1:2d}] ❌ 工具执行异常: {e}")
 
         print(f"📊 事件总数: {event_count}")
 
@@ -244,9 +252,7 @@ async def demo_direct_calls():
 
     event_count = 0
     async for event in simple_progress_tool.on_invoke_tool(
-        ctx,
-        '{"task_name": "系统维护"}',
-        "direct_call_demo"
+        ctx, '{"task_name": "系统维护"}', "direct_call_demo"
     ):
         event_count += 1
         if isinstance(event, NotifyStreamEvent):
@@ -315,7 +321,7 @@ async def demo_key_concepts():
         ("事件标签", "NotifyStreamEvent(tag='success')", "用于前端UI逻辑和事件分类"),
         ("增量输出", "NotifyStreamEvent(is_delta=True)", "用于打字机效果等流式文本"),
         ("终结信号", "yield '字符串' 后停止", "Runner会忽略后续的yield"),
-        ("上下文隔离", "StreamingToolContextEvent", "包装内部事件，实现隔离")
+        ("上下文隔离", "StreamingToolContextEvent", "包装内部事件，实现隔离"),
     ]
 
     print(f"{'概念':<12} {'代码示例':<35} {'说明'}")
@@ -332,6 +338,7 @@ async def demo_key_concepts():
 
 if __name__ == "__main__":
     """运行基础演示套件"""
+
     async def main():
         await demo_basic_concepts()
         await demo_direct_calls()

examples/json_object_compatibility_demo.py

@@ -29,6 +29,7 @@
 # 定义测试用的数据模型
 class UserProfile(BaseModel):
     """用户个人资料信息"""
+
     name: str = Field(description="用户的姓名")
     age: int = Field(description="用户的年龄", ge=0, le=150)
     city: str = Field(description="用户居住的城市")
@@ -39,6 +40,7 @@ class UserProfile(BaseModel):
 @dataclass
 class TaskItem:
     """任务项目"""
+
     title: str
     description: str
     priority: int  # 1-5, 5 为最高优先级
@@ -67,13 +69,16 @@ def demo_json_object_output_schema():
 
     print("\n验证 JSON 输出:")
     print("-" * 40)
-    test_json = json.dumps({
-        "name": "张三",
-        "age": 25,
-        "city": "北京",
-        "is_active": True,
-        "interests": ["编程", "阅读", "旅行"]
-    }, ensure_ascii=False)
+    test_json = json.dumps(
+        {
+            "name": "张三",
+            "age": 25,
+            "city": "北京",
+            "is_active": True,
+            "interests": ["编程", "阅读", "旅行"],
+        },
+        ensure_ascii=False,
+    )
 
     try:
         validated_result = output_schema.validate_json(test_json)
@@ -112,15 +117,15 @@ def demo_validation():
     schema = JsonObjectOutputSchema(UserProfile)
 
     # 测试有效的 JSON
-    valid_json = '''
+    valid_json = """
     {
         "name": "张三",
         "age": 25,
         "city": "北京",
         "is_active": true,
         "interests": ["编程", "阅读", "旅行"]
     }
-    '''
+    """
 
     print("验证有效 JSON:")
     print("-" * 40)
@@ -132,15 +137,15 @@ def demo_validation():
         print(f"验证失败: {e}")
 
     # 测试需要修复的 JSON（缺少引号）
-    malformed_json = '''
+    malformed_json = """
     {
         name: "李四",
         age: 30,
         city: "上海",
         is_active: true,
         interests: ["音乐", "运动"]
     }
-    '''
+    """
 
     print("\n验证需要修复的 JSON:")
     print("-" * 40)
@@ -164,14 +169,14 @@ def demo_dataclass_support():
     print(f"- 目标类型: {schema.target_type.__name__}")
 
     # 测试验证
-    test_json = '''
+    test_json = """
     {
         "title": "完成项目文档",
         "description": "编写项目的技术文档和用户手册",
         "priority": 1,
         "completed": false
     }
-    '''
+    """
 
     print("\n验证 dataclass JSON:")
     print("-" * 40)
@@ -203,10 +208,7 @@ def demo_custom_instructions():
 Output only valid JSON with no additional text or explanations.
 """
 
-    schema = JsonObjectOutputSchema(
-        UserProfile,
-        custom_instructions=custom_instructions
-    )
+    schema = JsonObjectOutputSchema(UserProfile, custom_instructions=custom_instructions)
 
     print("自定义指令:")
     print("-" * 40)
@@ -223,22 +225,24 @@ def demo_agent_integration():
     json_object_agent = Agent(
         name="JsonObjectAgent",
         instructions="你是一个专业的用户信息处理助手",
-        output_type=JsonObjectOutputSchema(UserProfile)
+        output_type=JsonObjectOutputSchema(UserProfile),
     )
 
     print("JsonObjectOutputSchema Agent:")
     print(f"- Agent 名称: {json_object_agent.name}")
     print(f"- 输出类型: {type(json_object_agent.output_type).__name__}")
-    if json_object_agent.output_type and hasattr(json_object_agent.output_type, 'target_type'):
+    if json_object_agent.output_type and hasattr(json_object_agent.output_type, "target_type"):
         print(f"- 目标类型: {json_object_agent.output_type.target_type.__name__}")
-    if json_object_agent.output_type and hasattr(json_object_agent.output_type, 'should_inject_to_system_prompt'):
+    if json_object_agent.output_type and hasattr(
+        json_object_agent.output_type, "should_inject_to_system_prompt"
+    ):
         print(f"- 需要注入: {json_object_agent.output_type.should_inject_to_system_prompt()}")
 
     # 使用标准 AgentOutputSchema 的 Agent（业务层控制）
     standard_agent = Agent(
         name="StandardAgent",
         instructions="你是一个标准的用户信息处理助手",
-        output_type=AgentOutputSchema(UserProfile)
+        output_type=AgentOutputSchema(UserProfile),
     )
 
     print("\n标准 AgentOutputSchema Agent:")
@@ -247,9 +251,6 @@ def demo_agent_integration():
     print("- 说明: 业务层根据模型能力选择合适的 Schema")
 
 
-
-
-
 def demo_factory_methods():
     """演示工厂方法"""
     print("\n" + "=" * 60)
@@ -301,6 +302,7 @@ def main():
     except Exception as e:
         print(f"\n演示过程中出现错误: {e}")
         import traceback
+
         traceback.print_exc()
 
 

examples/reasoning_content/main.py

@@ -44,7 +44,7 @@ async def stream_with_reasoning_content():
         handoffs=[],
         tracing=ModelTracing.DISABLED,
         previous_response_id=None,
-        prompt=None
+        prompt=None,
     ):
         if event.type == "response.reasoning_summary_text.delta":
             print(
@@ -82,7 +82,7 @@ async def get_response_with_reasoning_content():
         handoffs=[],
         tracing=ModelTracing.DISABLED,
         previous_response_id=None,
-        prompt=None
+        prompt=None,
     )
 
     # Extract reasoning content and regular content from the response