fix(lint): resolve all 37 flake8 issues (#33)

src/daemon/base_task_handler.py

@@ -10,7 +10,7 @@ from dataclasses import dataclass
 from pathlib import Path
 from typing import Optional
 
-from src.daemon.prompt_composer import PromptContext, PromptComposer, PromptSection
+from src.daemon.prompt_composer import PromptContext, PromptSection
 from src.blackboard.db import get_connection
 
 logger = logging.getLogger("moziplus-v2.handler")
@@ -28,46 +28,46 @@ class VerifyResult:
 
 class BaseTaskHandler:
     """所有 task type handler 的基类。
-    
+
     职责：L2 引擎注入层的业务逻辑——prompt 构建、完成验证、状态标记。
     不管：进程生命周期、exit 分类、重试决策（这些归 spawner）。
     """
-    
+
     # crash 类 outcome（进程级异常，需要 rollback）
     CRASH_OUTCOMES = frozenset({
         "crashed", "compact_failed", "process_crash",
         "session_stuck", "compact_hanging",
     })
-    
+
     task_type: str = ""
     virtual_project: Optional[str] = None
     display_name: str = ""  # 中文展示名（ticker 扫描日志用）
-    
+
     # === 子类必须实现 ===
-    
+
     def build_prompt(self, context: PromptContext) -> str:
         """构建 L2 prompt（通过 PromptComposer 拼 section）。子类实现。"""
         raise NotImplementedError
-    
+
     def verify_completion(self, task_id: str, db_path: Path) -> VerifyResult:
         """验证任务完成质量。每个 handler 自己的验证逻辑。子类实现。"""
         raise NotImplementedError
-    
+
     def target_success_status(self) -> str:
         """验证通过后的目标状态。task='review', mail/toolchain='done'"""
         return "review"
-    
+
     def get_sections(self) -> list[PromptSection]:
         """返回此 handler 的 prompt section 列表。子类实现。"""
         return []
-    
+
     # === 基类提供统一流程 ===
-    
+
     def pre_spawn(self, task_id: str, db_path: Path) -> bool:
         """spawn 前业务准备。默认 True。
         mail/toolchain override 为 auto_working。"""
         return True
-    
+
     def post_complete(self, task_id: str, agent_id: str,
                       outcome: str, db_path: Path) -> None:
         """spawn 完成后的业务处理。统一 4 步流程：
@@ -80,10 +80,10 @@ class BaseTaskHandler:
         if outcome in self.CRASH_OUTCOMES:
             self._rollback_current_agent(db_path, task_id, agent_id)
             return
-        
+
         # 2. verify
         result = self.verify_completion(task_id, db_path)
-        
+
         # 3. mark
         if result.passed:
             self._mark_task_status(db_path, task_id, self.target_success_status())
@@ -92,20 +92,20 @@ class BaseTaskHandler:
         else:
             # 4. notify
             self.on_failure(task_id, agent_id, db_path, result)
-    
+
     def on_failure(self, task_id: str, agent_id: str,
                    db_path: Path, verify: VerifyResult) -> None:
         """验证失败处理。默认：标 failed。子类可 override。"""
         self._mark_task_status(db_path, task_id, "failed")
         logger.info("Task %s: verify failed (%s), marked failed",
-                     task_id, verify.reason)
-    
+                    task_id, verify.reason)
+
     def check_completion(self, task_id: str, db_path: Path) -> bool:
         """ticker 级别的完成检查。默认：False。"""
         return False
-    
+
     # === 内部工具方法 ===
-    
+
     def _rollback_current_agent(self, db_path: Path, task_id: str, agent_id: str) -> None:
         """crash 后回退 current_agent → assignee，避免 exclude_current 卡死。
         从 dispatcher._rollback_current_agent 迁移。"""
@@ -126,7 +126,7 @@ class BaseTaskHandler:
         except Exception as e:
             logger.warning("Task %s: failed to rollback current_agent: %s",
                            task_id, e)
-    
+
     def _mark_task_status(self, db_path: Path, task_id: str, status: str) -> None:
         """更新任务状态 + 写审计事件（带 3 次重试，防 SQLite DB 锁）。"""
         for attempt in range(3):
@@ -157,7 +157,7 @@ class BaseTaskHandler:
                 logger.warning("Handler: mark %s → %s attempt %d failed: %s",
                                task_id, status, attempt + 1, e)
         logger.error("Handler: mark %s → %s all 3 attempts failed", task_id, status)
-    
+
     def _auto_mark_working(self, task_id: str, db_path: Path) -> bool:
         """pending → working（mail/toolchain 通用）。"""
         try: