fix: lint - 114 errors fixed (unused imports, indentation, blank lines)

src/daemon/spawner.py

@@ -7,6 +7,7 @@ Subagent: 占位(实际通过 OpenClaw Gateway API sessions_spawn,F17 完善)
 from __future__ import annotations
 
 import asyncio
+import pathlib
 import json
 import logging
 import os
@@ -15,7 +16,7 @@ from datetime import datetime
 from pathlib import Path
 from typing import Any, Dict, List, Optional
 
-from src.blackboard.db import get_connection, init_db
+from src.blackboard.db import get_connection
 
 logger = logging.getLogger("moziplus-v2.spawner")
 
@@ -299,7 +300,7 @@ class AgentSpawner:
             project_id, agent_id)
 
     def _build_minimal_fallback(self, task_id, title, description, must_haves,
-                             project_id, agent_id):
+                                project_id, agent_id):
         """最小 fallback:只有任务上下文 + API 指令"""
         task_section = f"""## 任务
 {title}
@@ -311,7 +312,7 @@ class AgentSpawner:
         return task_section + "\n\n---\n\n" + api_section
 
     def _build_api_section(self, project_id: str, task_id: str,
-                            agent_id: str) -> str:
+                           agent_id: str) -> str:
         """构建 API 回写操作指令(BootstrapBuilder 模式下补充)"""
         # mail 任务直接 done,不走 review
         success_status = '"done"' if project_id == "_mail" else '"review"'
@@ -337,8 +338,8 @@ curl -X POST http://{self.api_host}:{self.api_port}/api/projects/{project_id}/ta
 """
 
     def _build_discussion_prompt(self, task_id: str, title: str,
-                                  description: str, must_haves: str,
-                                  project_id: str, agent_id: str) -> str:
+                                 description: str, must_haves: str,
+                                 project_id: str, agent_id: str) -> str:
         """构建讨论类 spawn prompt(§3.3 框架 + Boids)"""
         goal_snapshot = description or title
         constraints = must_haves or "(无特殊约束)"
@@ -379,9 +380,8 @@ curl -X POST http://{self.api_host}:{self.api_port}/api/projects/{project_id}/ta
             return router.agent_profiles.get(agent_id)
         return None
 
-
     def _build_mail_prompt(self, task_id: str, title: str, description: str,
-                            must_haves: str, agent_id: str) -> str:
+                           must_haves: str, agent_id: str) -> str:
         """构建 Mail 专用精简模板"""
         # 解析 must_haves 获取 from 和 performative
         from_agent = agent_id
@@ -575,7 +575,7 @@ curl -X POST http://{self.api_host}:{self.api_port}/api/projects/{project_id}/ta
                 stderr=asyncio.subprocess.PIPE,
             )
             self._register_session(session_id, agent_id, task_id, proc.pid,
-                                     broadcast_task_ids=broadcast_task_ids)
+                                   broadcast_task_ids=broadcast_task_ids)
             logger.info("Spawned agent %s (session=%s, pid=%d)",
                         agent_id, session_id, proc.pid)
 
@@ -852,7 +852,7 @@ curl -X POST http://{api_host}:{api_port}/api/projects/{project_id}/tasks/{task_
                 self.counter.set_cooldown(agent_id, seconds=60)
                 logger.info("Crash cooldown set for %s: 60s (outcome=%s)", agent_id, outcome)
             elif outcome in ("compact_failed", "process_crash", "session_stuck",
-                           "compact_hanging", "agent_error", "compact_interrupted") and self.counter:
+                             "compact_hanging", "agent_error", "compact_interrupted") and self.counter:
                 self.counter.set_cooldown(agent_id, seconds=300)  # 5 分钟
                 logger.info("Error cooldown set for %s: 300s (outcome=%s)", agent_id, outcome)
             # F1: 不可恢复 outcome → 立刻标 failed + 写黑板
@@ -881,7 +881,7 @@ curl -X POST http://{api_host}:{api_port}/api/projects/{project_id}/tasks/{task_
         except Exception:
             pass
 
-        stderr_text = b"".join(stderr_chunks).decode("utf-8", errors="replace")
+        _ = b"".join(stderr_chunks).decode("utf-8", errors="replace")
 
         # 检查 session 状态
         state = self._check_session_state(agent_id)
@@ -1428,7 +1428,7 @@ curl -X POST http://{api_host}:{api_port}/api/projects/{project_id}/tasks/{task_
         return defaults
 
     def _update_retry_counts(self, db_path: Optional[Path],
-                              task_id: Optional[str], counts: dict):
+                             task_id: Optional[str], counts: dict):
         """将 retry counts 写回最新 task_attempt 的 metadata"""
         if not db_path or not task_id:
             return
@@ -1488,8 +1488,8 @@ curl -X POST http://{api_host}:{api_port}/api/projects/{project_id}/tasks/{task_
                         from src.blackboard.operations import Blackboard
                         bb = Blackboard(db_path)
                         cid = bb.add_comment(task_id, "daemon",
-                            f"@pangtong-fujunshi 任务执行失败: {reason}，请评估是否需要介入",
-                            comment_type="system")
+                                             f"@pangtong-fujunshi 任务执行失败: {reason}，请评估是否需要介入",
+                                             comment_type="system")
                         bb.record_mentions(cid, task_id, ["pangtong-fujunshi"])
                         logger.info("Task %s: failure notified pangtong via comment+mention (reason=%s)", task_id, reason)
                 except Exception as e: