feat(core): GenAI for Beginners 课程借鉴 P1 九项落地（独立于 #181）

app_server/__main__.py

@@ -10,7 +10,6 @@
 import time
 from pathlib import Path
 
-
 _PROCESS_STARTED = time.perf_counter()
 
 

app_server/protocol/codec.py

@@ -8,7 +8,6 @@
 from app_server.errors import InvalidRequest, ParseError
 from app_server.protocol.models import Request
 
-
 DEFAULT_MAX_MESSAGE_BYTES = 1024 * 1024
 
 

app_server/protocol/models.py

@@ -5,7 +5,6 @@
 from dataclasses import dataclass, field
 from typing import Any
 
-
 RpcId = str | int | None
 
 

cli/automation_cli.py

@@ -19,7 +19,6 @@
 )
 from core.domain.automation import AutomationActivationStatus, AutomationScheduleKind
 
-
 ApplicationFactory = Callable[[], DeepCodeApplication]
 
 

cli/automation_foreground.py

@@ -17,7 +17,6 @@
 from core.domain.automation import AutomationRunStatus
 from core.domain.event import DomainEvent
 
-
 _EVENT_PAGE_SIZE = 500
 _LIVE_WAKE_SECONDS = 0.25
 

cli/loop_cli.py

@@ -23,8 +23,6 @@
 
 from rich.console import Console
 
-from cli.tui import theme
-
 from cli.execution_options import (
     add_access_preset_argument,
     add_reasoning_effort_argument,
@@ -37,6 +35,7 @@
     resume_goal,
     run_goal,
 )
+from cli.tui import theme
 from cli.tui.renderer import EventRenderer
 from core.application.errors import ApplicationError
 from core.config import ConfigError

cli/mcp_server.py

@@ -25,7 +25,7 @@
 import uuid
 from typing import Any
 
-import mcp.types as types
+from mcp import types
 from mcp.server.lowlevel import Server
 from mcp.server.stdio import stdio_server
 

cli/plugin_cli.py

@@ -6,8 +6,8 @@
 import json
 import sys
 
-from core.application.plugin_service import PluginDiscovery, PluginInfo, PluginService
 from core.application.errors import ApplicationError
+from core.application.plugin_service import PluginDiscovery, PluginInfo, PluginService
 from core.plugins.host import LocalPluginHost
 from core.skills.host import SkillWorkspaceRegistry
 

cli/schedule_cli.py

@@ -25,10 +25,9 @@
 
 from rich.console import Console
 
-from cli.tui import theme
-
-from cli.goal_runner import GoalRunOptions, run_goal
 from cli.execution_options import add_reasoning_effort_argument
+from cli.goal_runner import GoalRunOptions, run_goal
+from cli.tui import theme
 from core.domain.thread_goal import ThreadGoalStatus
 from core.loop.autodream import consolidate_memory
 from core.schedule.keepalive import Continuation
@@ -63,7 +62,7 @@ async def task(run_index: int) -> RunOutcome:
     return task
 
 
-def _loop_task(args) -> "callable":
+def _loop_task(args) -> callable:
     async def task(run_index: int) -> RunOutcome:
         workspace = os.path.abspath(args.workspace)
         result = await run_goal(

cli/skill_cli.py

@@ -7,10 +7,10 @@
 import os
 import sys
 
-from core.skills.management import LocalSkillManager
-from core.skills.models import MUTABLE_SKILL_SCOPES, SkillRecord, SkillScope
 from core.plugins.host import LocalPluginHost
 from core.skills.host import SkillWorkspaceRegistry
+from core.skills.management import LocalSkillManager
+from core.skills.models import MUTABLE_SKILL_SCOPES, SkillRecord, SkillScope
 
 
 def _parser() -> argparse.ArgumentParser:

cli/transcript.py

@@ -10,12 +10,12 @@ class TranscriptMode(StrEnum):
     VERBOSE = "verbose"
     SUMMARY = "summary"
 
-    def next(self) -> "TranscriptMode":
+    def next(self) -> TranscriptMode:
         modes = tuple(type(self))
         return modes[(modes.index(self) + 1) % len(modes)]
 
     @classmethod
-    def parse(cls, value: str) -> "TranscriptMode":
+    def parse(cls, value: str) -> TranscriptMode:
         clean = value.strip().lower()
         try:
             return cls(clean)

cli/tui/app.py

@@ -60,7 +60,6 @@
 from core.file_lock import FileLease
 from core.providers.reasoning import normalize_reasoning_effort
 
-
 _MODEL_CATALOG_PREVIEW = 4  # models shown per connection in /model
 # Sentinel: switch_model keeps the session's effort unless told otherwise.
 _KEEP_EFFORT: object = object()
@@ -313,7 +312,7 @@ def model_overview(self) -> str:
             else:
                 catalog = "no catalog configured — any model id accepted"
             marker = " · current" if view.get("id") == profile.connection_id else ""
-            lines.append(f"  {str(view.get('id', '')):<{width}}  {catalog}{marker}")
+            lines.append(f"  {view.get('id', '')!s:<{width}}  {catalog}{marker}")
         return "\n".join(lines)
 
     def connection_model_catalog(self) -> list[tuple[str, list[dict]]]:

cli/tui/domain_events.py

@@ -8,7 +8,6 @@
 from core.application.event_service import DeliveryBatch, EventService
 from core.domain.event import DomainEvent
 
-
 _REPLAY_PAGE_SIZE = 500
 
 

cli/tui/renderer.py

@@ -41,7 +41,6 @@
 from core.events.protocol import Event
 from core.reasoning import ReasoningAvailability, ReasoningChannel
 
-
 _NORMAL_PREVIEW_CHARS = 240
 _STATUS_DETAIL_CHARS = 72
 _SUBJECT_CELLS = 88  # ceiling; the real budget is the terminal's width

core/agent_runtime/compaction.py

@@ -8,7 +8,8 @@
 
 from __future__ import annotations
 
-from typing import Any, Mapping, Protocol
+from collections.abc import Mapping
+from typing import Any, Protocol
 
 from core.agent_runtime.helpers import find_legal_message_start
 

core/agent_runtime/context.py

@@ -3,10 +3,11 @@
 from __future__ import annotations
 
 import os
+from collections.abc import Mapping
 from dataclasses import dataclass
 from datetime import datetime
 from pathlib import Path
-from typing import Any, Mapping
+from typing import Any
 from xml.sax.saxutils import escape
 
 
@@ -47,7 +48,7 @@ class EnvironmentContext:
     timezone: str
 
     @classmethod
-    def for_workspace(cls, workspace: str | Path) -> "EnvironmentContext":
+    def for_workspace(cls, workspace: str | Path) -> EnvironmentContext:
         now = datetime.now().astimezone()
         return cls(
             cwd=str(Path(workspace).expanduser().resolve(strict=False)),

core/agent_runtime/goal_runtime.py

@@ -6,7 +6,6 @@
 from dataclasses import dataclass
 from typing import Any, Protocol
 
-
 GOAL_TOOL_NAMES = frozenset({"get_goal", "update_goal"})
 _GOAL_CLOSURE_PROMPT = """\
 Before ending this Goal-associated Turn, call get_goal and compare the latest

core/agent_runtime/hook.py

@@ -43,8 +43,6 @@ async def before_iteration(self, context: AgentHookContext) -> None:
     async def before_model_request(self, context: AgentHookContext) -> None:
         """Observe a user-visible model request before provider I/O begins."""
 
-        pass
-
     async def on_stream(self, context: AgentHookContext, delta: str) -> None:
         pass
 
@@ -62,8 +60,6 @@ async def on_stream_end(self, context: AgentHookContext, *, resuming: bool) -> N
     async def on_model_response(self, context: AgentHookContext) -> None:
         """Observe one completed provider response before tools can run."""
 
-        pass
-
     async def before_execute_tools(self, context: AgentHookContext) -> None:
         pass
 

core/agent_runtime/processes.py

@@ -36,7 +36,7 @@ async def terminate_process_tree(
         return
     try:
         await asyncio.wait_for(process.wait(), timeout=grace_seconds)
-    except asyncio.TimeoutError:
+    except TimeoutError:
         pass
     try:
         os.killpg(process.pid, signal.SIGKILL)