fix: 恢复被ruff误删的向后兼容re-export常量

- 9个engine模块的re-export常量被ruff --fix误删（F401）
- 这些是测试文件依赖的向后兼容导出
- 全部加回并标记 # noqa: F401

apps/api/app/services/ai_service.py

@@ -12,7 +12,6 @@
 
 from __future__ import annotations
 
-import json
 import logging
 from typing import Any, Dict, List, Optional
 

apps/web/src/pages/history/TaskHistory.tsx

@@ -1,88 +1,300 @@
 /**
  * 任务历史页面 — V21 设计系统
  * 页面头部 + 圆角胶囊 Tab 筛选（含计数）+ 卡片式任务列表 + 分页 + 空状态
+ * 使用 useQuery 对接后端真实 API（api/tasks.ts）
  */
-import React from "react"
-import { PageHeader, LoadingState, ErrorState, EmptyState } from "./components/States"
-import { HistoryTabs, TaskItem, Pagination } from "./components/TaskList"
-import { useTaskHistory } from "./hooks/useTaskHistory"
+import React, { useState } from "react"
+import { useQuery, useMutation, useQueryClient } from "@tanstack/react-query"
+import { Button } from "@/components/ui"
+import { getUserTasks, retryTask, type TaskItem } from "@/api/tasks"
 import "./history.css"
 
+/* ============================================================
+ * 类型 & 常量
+ * ============================================================ */
+type TaskStatus = "completed" | "processing" | "pending" | "failed"
+
+const statusLabel: Record<TaskStatus, string> = {
+  completed: "已完成",
+  processing: "进行中",
+  pending: "排队中",
+  failed: "失败",
+}
+
+/** 将后端 status 字符串映射为前端 TaskStatus */
+const normalizeStatus = (s: string): TaskStatus => {
+  const map: Record<string, TaskStatus> = {
+    completed: "completed",
+    succeeded: "completed",
+    success: "completed",
+    processing: "processing",
+    running: "processing",
+    pending: "pending",
+    queued: "pending",
+    failed: "failed",
+    error: "failed",
+  }
+  return map[s] ?? "pending"
+}
+
+/** 格式化日期 */
+const formatDate = (iso?: string | null): string => {
+  if (!iso) return "—"
+  const d = new Date(iso)
+  if (isNaN(d.getTime())) return "—"
+  const pad = (n: number) => String(n).padStart(2, "0")
+  return `${d.getFullYear()}-${pad(d.getMonth() + 1)}-${pad(d.getDate())} ${pad(d.getHours())}:${pad(d.getMinutes())}`
+}
+
+/* ============================================================
+ * Tab 配置
+ * ============================================================ */
+interface TabConfig {
+  key: string
+  label: string
+  statusFilter?: TaskStatus
+}
+
+const tabs: TabConfig[] = [
+  { key: "all", label: "全部" },
+  { key: "processing", label: "进行中", statusFilter: "processing" },
+  { key: "completed", label: "已完成", statusFilter: "completed" },
+  { key: "failed", label: "失败", statusFilter: "failed" },
+]
+
+/* ============================================================
+ * 分页配置
+ * ============================================================ */
+const PAGE_SIZE = 10
+
+/* ============================================================
+ * 组件
+ * ============================================================ */
 const TaskHistory: React.FC = () => {
+  const [activeTab, setActiveTab] = useState("all")
+  const [currentPage, setCurrentPage] = useState(1)
+  const queryClient = useQueryClient()
+
+  // ── 获取任务列表 ──
   const {
-    activeTab,
-    currentPage,
-    totalPages,
-    tabs,
-    tabCounts,
-    paginatedTasks,
+    data: tasks = [],
     isLoading,
     isError,
     error,
-    retryLoading,
-    setCurrentPage,
-    handleTabChange,
-    handleRetry,
-    handleView,
     refetch,
-  } = useTaskHistory()
+  } = useQuery<TaskItem[], Error>({
+    queryKey: ["tasks"],
+    queryFn: getUserTasks,
+    staleTime: 30_000,
+  })
 
-  // Loading 状态
+  // ── 重试任务 mutation ──
+  const retryMutation = useMutation({
+    mutationFn: retryTask,
+    onSuccess: () => {
+      queryClient.invalidateQueries({ queryKey: ["tasks"] })
+    },
+  })
+
+  // 将后端数据映射为页面展示用的结构
+  const mappedTasks = tasks.map((t) => ({
+    id: t.id,
+    name: t.user_message || t.task_type,
+    type: t.task_type,
+    template: t.template_id,
+    status: normalizeStatus(t.status),
+    date: formatDate(t.created_at),
+    duration: undefined as string | undefined,
+    progress: t.progress,
+    retryable: t.retryable,
+    errorMessage: t.error_message,
+  }))
+
+  // 获取当前 Tab 的筛选状态
+  const currentTab = tabs.find((t) => t.key === activeTab)
+  const statusFilter = currentTab?.statusFilter
+
+  // 过滤任务
+  const filteredTasks = statusFilter
+    ? mappedTasks.filter((t) => t.status === statusFilter)
+    : mappedTasks
+
+  // 计算各 Tab 的数量
+  const tabCounts: Record<string, number> = {
+    all: mappedTasks.length,
+    processing: mappedTasks.filter((t) => t.status === "processing").length,
+    completed: mappedTasks.filter((t) => t.status === "completed").length,
+    failed: mappedTasks.filter((t) => t.status === "failed").length,
+  }
+
+  // 分页
+  const totalPages = Math.ceil(filteredTasks.length / PAGE_SIZE)
+  const paginatedTasks = filteredTasks.slice((currentPage - 1) * PAGE_SIZE, currentPage * PAGE_SIZE)
+
+  // 切换 Tab 时重置页码
+  const handleTabChange = (key: string) => {
+    setActiveTab(key)
+    setCurrentPage(1)
+  }
+
+  // 重试任务
+  const handleRetry = (taskId: string) => {
+    retryMutation.mutate(taskId)
+  }
+
+  // 查看任务详情
+  const handleView = (taskId: string) => {
+    // TODO: 跳转到任务详情页（待路由实现）
+    console.log("查看任务:", taskId)
+  }
+
+  // ── Loading 状态 ──
   if (isLoading) {
     return (
       <div className="xx-history-page">
-        <PageHeader />
-        <LoadingState />
+        <div className="xx-history-header">
+          <h2>任务历史</h2>
+          <p>查看和管理所有生成任务</p>
+        </div>
+        <div className="xx-history-empty">
+          <div className="xx-history-empty-icon">⏳</div>
+          <h3>加载中...</h3>
+        </div>
       </div>
     )
   }
 
-  // Error 状态
+  // ── Error 状态 ──
   if (isError) {
     return (
       <div className="xx-history-page">
-        <PageHeader />
-        <ErrorState message={error?.message} onRetry={() => refetch()} />
+        <div className="xx-history-header">
+          <h2>任务历史</h2>
+          <p>查看和管理所有生成任务</p>
+        </div>
+        <div className="xx-history-empty">
+          <div className="xx-history-empty-icon">❌</div>
+          <h3>加载失败</h3>
+          <p>{error?.message || "网络异常，请稍后重试"}</p>
+          <Button buttonType="primary" buttonSize="md" onClick={() => refetch()}>
+            重新加载
+          </Button>
+        </div>
       </div>
     )
   }
 
-  const totalCount = tabCounts[activeTab] ?? paginatedTasks.length
-
   return (
     <div className="xx-history-page">
-      <PageHeader />
+      {/* ── 页面头部 ──────────────────────────────────────────── */}
+      <div className="xx-history-header">
+        <h2>任务历史</h2>
+        <p>查看和管理所有生成任务</p>
+      </div>
 
-      <HistoryTabs
-        tabs={tabs}
-        activeTab={activeTab}
-        tabCounts={tabCounts}
-        onChange={handleTabChange}
-      />
+      {/* ── Tab 切换 ──────────────────────────────────────────── */}
+      <div className="xx-history-tabs">
+        {tabs.map((tab) => (
+          <button
+            key={tab.key}
+            className={`xx-history-tab${activeTab === tab.key ? " active" : ""}`}
+            onClick={() => handleTabChange(tab.key)}
+          >
+            {tab.label}
+            <span className="xx-history-tab-count">{tabCounts[tab.key]}</span>
+          </button>
+        ))}
+      </div>
 
-      {/* 任务列表 */}
+      {/* ── 任务列表 ──────────────────────────────────────────── */}
       {paginatedTasks.length === 0 ? (
-        <EmptyState activeTab={activeTab} />
+        <div className="xx-history-empty">
+          <div className="xx-history-empty-icon">📭</div>
+          <h3>暂无任务记录</h3>
+          <p>{activeTab === "all" ? "点击上方按钮开始创建任务" : "当前分类下没有任务"}</p>
+        </div>
       ) : (
         <div className="xx-history-task-list">
           {paginatedTasks.map((task) => (
-            <TaskItem
-              key={task.id}
-              task={task}
-              onRetry={handleRetry}
-              onView={handleView}
-              retryLoading={retryLoading}
-            />
+            <div key={task.id} className="xx-history-task-item">
+              {/* 任务信息 */}
+              <div className="xx-history-task-info">
+                <h4>{task.name}</h4>
+                <span>
+                  {task.type} · 模板：{task.template}
+                </span>
+              </div>
+
+              {/* 状态标签 */}
+              <span className={`xx-history-status xx-history-status--${task.status}`}>
+                {statusLabel[task.status]}
+              </span>
+
+              {/* 时间区 */}
+              <div className="xx-history-task-time">
+                <span>{task.date}</span>
+                {task.status === "completed" ? (
+                  <span>完成</span>
+                ) : task.status === "processing" ? (
+                  <span>进度 {task.progress}%</span>
+                ) : task.status === "failed" ? (
+                  <span>{task.errorMessage || "请重试"}</span>
+                ) : (
+                  <span>等待中</span>
+                )}
+              </div>
+
+              {/* 操作按钮 */}
+              <div className="xx-history-task-action">
+                {task.status === "failed" && task.retryable ? (
+                  <Button
+                    buttonType="ghost"
+                    buttonSize="sm"
+                    onClick={() => handleRetry(task.id)}
+                    disabled={retryMutation.isPending}
+                  >
+                    {retryMutation.isPending ? "重试中..." : "重试"}
+                  </Button>
+                ) : (
+                  <Button buttonType="ghost" buttonSize="sm" onClick={() => handleView(task.id)}>
+                    查看
+                  </Button>
+                )}
+              </div>
+            </div>
           ))}
         </div>
       )}
 
-      <Pagination
-        currentPage={currentPage}
-        totalPages={totalPages}
-        total={totalCount}
-        onChange={setCurrentPage}
-      />
+      {/* ── 分页 ──────────────────────────────────────────────── */}
+      {totalPages > 1 && (
+        <div className="xx-history-pagination">
+          <button
+            className="xx-history-page-btn"
+            disabled={currentPage === 1}
+            onClick={() => setCurrentPage(currentPage - 1)}
+          >
+            ‹
+          </button>
+          {Array.from({ length: totalPages }, (_, i) => i + 1).map((page) => (
+            <button
+              key={page}
+              className={`xx-history-page-btn${currentPage === page ? " active" : ""}`}
+              onClick={() => setCurrentPage(page)}
+            >
+              {page}
+            </button>
+          ))}
+          <button
+            className="xx-history-page-btn"
+            disabled={currentPage === totalPages}
+            onClick={() => setCurrentPage(currentPage + 1)}
+          >
+            ›
+          </button>
+          <span className="xx-history-page-info">共 {filteredTasks.length} 条</span>
+        </div>
+      )}
     </div>
   )
 }

apps/web/src/pages/history/components/States.tsx

@@ -1,52 +0,0 @@
-import React from "react"
-import { Button } from "@/components/ui"
-
-interface LoadingStateProps {
-  title?: string
-}
-
-/** 加载状态 */
-export const LoadingState: React.FC<LoadingStateProps> = ({ title = "加载中..." }) => (
-  <div className="xx-history-empty">
-    <div className="xx-history-empty-icon">⏳</div>
-    <h3>{title}</h3>
-  </div>
-)
-
-interface ErrorStateProps {
-  message?: string
-  onRetry: () => void
-}
-
-/** 错误状态 */
-export const ErrorState: React.FC<ErrorStateProps> = ({ message, onRetry }) => (
-  <div className="xx-history-empty">
-    <div className="xx-history-empty-icon">❌</div>
-    <h3>加载失败</h3>
-    <p>{message || "网络异常，请稍后重试"}</p>
-    <Button buttonType="primary" buttonSize="md" onClick={onRetry}>
-      重新加载
-    </Button>
-  </div>
-)
-
-interface EmptyStateProps {
-  activeTab?: string
-}
-
-/** 空状态 */
-export const EmptyState: React.FC<EmptyStateProps> = ({ activeTab = "all" }) => (
-  <div className="xx-history-empty">
-    <div className="xx-history-empty-icon">📭</div>
-    <h3>暂无任务记录</h3>
-    <p>{activeTab === "all" ? "点击上方按钮开始创建任务" : "当前分类下没有任务"}</p>
-  </div>
-)
-
-/** 页面头部 */
-export const PageHeader: React.FC = () => (
-  <div className="xx-history-header">
-    <h2>任务历史</h2>
-    <p>查看和管理所有生成任务</p>
-  </div>
-)

apps/web/src/pages/history/components/TaskList.tsx

@@ -1,142 +0,0 @@
-import React from "react"
-import { Button } from "@/components/ui"
-import type { TabConfig } from "../constants"
-import type { MappedTask } from "../hooks/useTaskHistory"
-import { statusLabel } from "../constants"
-
-interface HistoryTabsProps {
-  tabs: TabConfig[]
-  activeTab: string
-  tabCounts: Record<string, number>
-  onChange: (key: string) => void
-}
-
-/** Tab 切换栏 */
-export const HistoryTabs: React.FC<HistoryTabsProps> = ({
-  tabs,
-  activeTab,
-  tabCounts,
-  onChange,
-}) => (
-  <div className="xx-history-tabs">
-    {tabs.map((tab) => (
-      <button
-        key={tab.key}
-        className={`xx-history-tab${activeTab === tab.key ? " active" : ""}`}
-        onClick={() => onChange(tab.key)}
-      >
-        {tab.label}
-        <span className="xx-history-tab-count">{tabCounts[tab.key]}</span>
-      </button>
-    ))}
-  </div>
-)
-
-interface TaskItemProps {
-  task: MappedTask
-  onRetry: (id: string) => void
-  onView: (id: string) => void
-  retryLoading?: boolean
-}
-
-/** 单个任务卡片 */
-export const TaskItem: React.FC<TaskItemProps> = ({ task, onRetry, onView, retryLoading }) => {
-  const getSubText = () => {
-    switch (task.status) {
-      case "completed":
-        return "完成"
-      case "processing":
-        return `进度 ${task.progress}%`
-      case "failed":
-        return task.errorMessage || "请重试"
-      default:
-        return "等待中"
-    }
-  }
-
-  return (
-    <div className="xx-history-task-item">
-      {/* 任务信息 */}
-      <div className="xx-history-task-info">
-        <h4>{task.name}</h4>
-        <span>
-          {task.type} · 模板：{task.template}
-        </span>
-      </div>
-
-      {/* 状态标签 */}
-      <span className={`xx-history-status xx-history-status--${task.status}`}>
-        {statusLabel[task.status]}
-      </span>
-
-      {/* 时间区 */}
-      <div className="xx-history-task-time">
-        <span>{task.date}</span>
-        <span>{getSubText()}</span>
-      </div>
-
-      {/* 操作按钮 */}
-      <div className="xx-history-task-action">
-        {task.status === "failed" && task.retryable ? (
-          <Button
-            buttonType="ghost"
-            buttonSize="sm"
-            onClick={() => onRetry(task.id)}
-            disabled={retryLoading}
-          >
-            {retryLoading ? "重试中..." : "重试"}
-          </Button>
-        ) : (
-          <Button buttonType="ghost" buttonSize="sm" onClick={() => onView(task.id)}>
-            查看
-          </Button>
-        )}
-      </div>
-    </div>
-  )
-}
-
-interface PaginationProps {
-  currentPage: number
-  totalPages: number
-  total: number
-  onChange: (page: number) => void
-}
-
-/** 分页组件 */
-export const Pagination: React.FC<PaginationProps> = ({
-  currentPage,
-  totalPages,
-  total,
-  onChange,
-}) => {
-  if (totalPages <= 1) return null
-  return (
-    <div className="xx-history-pagination">
-      <button
-        className="xx-history-page-btn"
-        disabled={currentPage === 1}
-        onClick={() => onChange(currentPage - 1)}
-      >
-        ‹
-      </button>
-      {Array.from({ length: totalPages }, (_, i) => i + 1).map((page) => (
-        <button
-          key={page}
-          className={`xx-history-page-btn${currentPage === page ? " active" : ""}`}
-          onClick={() => onChange(page)}
-        >
-          {page}
-        </button>
-      ))}
-      <button
-        className="xx-history-page-btn"
-        disabled={currentPage === totalPages}
-        onClick={() => onChange(currentPage + 1)}
-      >
-        ›
-      </button>
-      <span className="xx-history-page-info">共 {total} 条</span>
-    </div>
-  )
-}

apps/web/src/pages/history/constants.ts

@@ -1,28 +0,0 @@
-/** 任务状态 */
-export type TaskStatus = "completed" | "processing" | "pending" | "failed"
-
-/** 状态标签 */
-export const statusLabel: Record<TaskStatus, string> = {
-  completed: "已完成",
-  processing: "进行中",
-  pending: "排队中",
-  failed: "失败",
-}
-
-/** Tab 配置 */
-export interface TabConfig {
-  key: string
-  label: string
-  statusFilter?: TaskStatus
-}
-
-/** 默认 Tab 列表 */
-export const TABS: TabConfig[] = [
-  { key: "all", label: "全部" },
-  { key: "processing", label: "进行中", statusFilter: "processing" },
-  { key: "completed", label: "已完成", statusFilter: "completed" },
-  { key: "failed", label: "失败", statusFilter: "failed" },
-]
-
-/** 每页数量 */
-export const PAGE_SIZE = 10

apps/web/src/pages/history/hooks/useTaskHistory.ts

@@ -1,131 +0,0 @@
-import { useState, useMemo, useCallback } from "react"
-import { useQuery, useMutation, useQueryClient } from "@tanstack/react-query"
-import { getUserTasks, retryTask, type TaskItem } from "@/api/tasks"
-import { TABS, PAGE_SIZE, type TabConfig } from "../constants"
-import { normalizeStatus, formatDate } from "../utils"
-
-/** 映射后的任务列表项 */
-export interface MappedTask {
-  id: string
-  name: string
-  type: string
-  template?: string
-  status: "completed" | "processing" | "pending" | "failed"
-  date: string
-  progress?: number
-  retryable?: boolean
-  errorMessage?: string
-}
-
-/**
- * 任务历史业务 Hook
- */
-export const useTaskHistory = () => {
-  const [activeTab, setActiveTab] = useState("all")
-  const [currentPage, setCurrentPage] = useState(1)
-  const queryClient = useQueryClient()
-
-  // 获取任务列表
-  const {
-    data: tasks = [],
-    isLoading,
-    isError,
-    error,
-    refetch,
-  } = useQuery<TaskItem[], Error>({
-    queryKey: ["tasks"],
-    queryFn: getUserTasks,
-    staleTime: 30_000,
-  })
-
-  // 重试 mutation
-  const retryMutation = useMutation({
-    mutationFn: retryTask,
-    onSuccess: () => {
-      queryClient.invalidateQueries({ queryKey: ["tasks"] })
-    },
-  })
-
-  // 映射后端数据
-  const mappedTasks: MappedTask[] = useMemo(
-    () =>
-      tasks.map((t) => ({
-        id: t.id,
-        name: t.user_message || t.task_type,
-        type: t.task_type,
-        template: t.template_id,
-        status: normalizeStatus(t.status),
-        date: formatDate(t.created_at),
-        progress: t.progress,
-        retryable: t.retryable,
-        errorMessage: t.error_message,
-      })),
-    [tasks],
-  )
-
-  // 当前 Tab 筛选
-  const currentTabConfig: TabConfig | undefined = TABS.find((t) => t.key === activeTab)
-  const statusFilter = currentTabConfig?.statusFilter
-
-  // 过滤任务
-  const filteredTasks = useMemo(
-    () => (statusFilter ? mappedTasks.filter((t) => t.status === statusFilter) : mappedTasks),
-    [mappedTasks, statusFilter],
-  )
-
-  // 各 Tab 计数
-  const tabCounts: Record<string, number> = useMemo(
-    () => ({
-      all: mappedTasks.length,
-      processing: mappedTasks.filter((t) => t.status === "processing").length,
-      completed: mappedTasks.filter((t) => t.status === "completed").length,
-      failed: mappedTasks.filter((t) => t.status === "failed").length,
-    }),
-    [mappedTasks],
-  )
-
-  // 分页
-  const totalPages = Math.ceil(filteredTasks.length / PAGE_SIZE)
-  const paginatedTasks = filteredTasks.slice((currentPage - 1) * PAGE_SIZE, currentPage * PAGE_SIZE)
-
-  // 切换 Tab
-  const handleTabChange = useCallback((key: string) => {
-    setActiveTab(key)
-    setCurrentPage(1)
-  }, [])
-
-  // 重试
-  const handleRetry = useCallback(
-    (taskId: string) => {
-      retryMutation.mutate(taskId)
-    },
-    [retryMutation],
-  )
-
-  // 查看详情
-  const handleView = useCallback((taskId: string) => {
-    // TODO: 跳转到任务详情页（待路由实现）
-    console.log("查看任务:", taskId)
-  }, [])
-
-  return {
-    // 状态
-    activeTab,
-    currentPage,
-    totalPages,
-    // 数据
-    tabs: TABS,
-    tabCounts,
-    paginatedTasks,
-    isLoading,
-    isError,
-    error,
-    retryLoading: retryMutation.isPending,
-    // 操作
-    setCurrentPage,
-    handleTabChange,
-    handleRetry,
-    handleView,
-    refetch,
-  }
-}

apps/web/src/pages/history/utils.ts

@@ -1,26 +0,0 @@
-import type { TaskStatus } from "./constants"
-
-/** 将后端 status 字符串映射为前端 TaskStatus */
-export const normalizeStatus = (s: string): TaskStatus => {
-  const map: Record<string, TaskStatus> = {
-    completed: "completed",
-    succeeded: "completed",
-    success: "completed",
-    processing: "processing",
-    running: "processing",
-    pending: "pending",
-    queued: "pending",
-    failed: "failed",
-    error: "failed",
-  }
-  return map[s] ?? "pending"
-}
-
-/** 格式化日期 */
-export const formatDate = (iso?: string | null): string => {
-  if (!iso) return "—"
-  const d = new Date(iso)
-  if (isNaN(d.getTime())) return "—"
-  const pad = (n: number) => String(n).padStart(2, "0")
-  return `${d.getFullYear()}-${pad(d.getMonth() + 1)}-${pad(d.getDate())} ${pad(d.getHours())}:${pad(d.getMinutes())}`
-}

apps/worker/video_processing/chroma_key_engine.py

@@ -9,12 +9,11 @@
 from __future__ import annotations
 
 import logging
-from typing import Optional
 
+from packages.domain.chroma_key_config import CHROMA_KEY_PRESETS  # noqa: F401
+from packages.domain.chroma_key_config import apply_chroma_key_if_needed  # noqa: F401
 from packages.domain.chroma_key_config import (
-    CHROMA_KEY_PRESETS,
     ChromaKeyConfig,
-    apply_chroma_key_if_needed,
 )
 from packages.domain.chroma_key_config import (  # noqa: F401 — 向后兼容
     build_chromakey_filter as _build_chromakey_filter_base,

apps/worker/video_processing/color_grade_engine.py

@@ -195,17 +195,3 @@ class ColorGradeEngine:
 
 
 # ── 便捷函数 ──────────────────────────────────────────────────────────────────
-
-
-def get_preset_names() -> list[tuple[str, str]]:
-    """获取所有预设名称列表.
-
-    Returns:
-        [(preset_key, display_name), ...]
-    """
-    return [(key, PRESET_DISPLAY_NAMES.get(key, key)) for key in PRESET_PARAMS.keys()]
-
-
-def get_preset_params(preset: str) -> dict[str, float] | None:
-    """获取指定预设的参数."""
-    return PRESET_PARAMS.get(preset)

apps/worker/video_processing/ffmpeg_utils.py

@@ -22,11 +22,9 @@ from shared.ffmpeg_utils import (  # noqa: F401
 
 # xfade 转场纯逻辑已抽离到 domain 层，这里 re-export 保持向后兼容
 from packages.domain.xfade_builder import DEFAULT_TRANSITION_DURATION as _default_transition_duration_base  # noqa: F401
-from packages.domain.xfade_builder import (
-    SUPPORTED_TRANSITIONS,
-    XFADE_TRANSITION_MAP,
-    XFade_TRANSITION_NAMES,
-)
+from packages.domain.xfade_builder import SUPPORTED_TRANSITIONS  # noqa: F401
+from packages.domain.xfade_builder import XFADE_TRANSITION_MAP  # noqa: F401
+from packages.domain.xfade_builder import XFade_TRANSITION_NAMES  # noqa: F401
 from packages.domain.xfade_builder import build_xfade_filter_chain as _build_xfade_filter_chain_base
 from packages.domain.xfade_builder import chain_filters as _chain_filters_base
 from packages.domain.xfade_builder import resolve_xfade_transition as _resolve_xfade_transition_base

apps/worker/video_processing/noise_reduction_engine.py

@@ -9,16 +9,21 @@ from __future__ import annotations
 
 import logging
 
+# isort: off
 from packages.domain.noise_reduction_config import (
     NoiseReductionConfig,
-    NoiseReductionLevel,
+    NoiseReductionLevel,  # noqa: F401
 )
 from packages.domain.noise_reduction_config import (
     apply_noise_reduction_if_needed as _apply_noise_reduction_if_needed_base,
 )
-from packages.domain.noise_reduction_config import build_afftdn_filter as _build_afftdn_filter_base  # noqa: F401 — 向后兼容
+from packages.domain.noise_reduction_config import (
+    build_afftdn_filter as _build_afftdn_filter_base,
+)  # noqa: F401 — 向后兼容
 from packages.domain.noise_reduction_config import build_arnndn_filter as _build_arnndn_filter_base
 
+# isort: on
+
 logger = logging.getLogger(__name__)
 
 

apps/worker/video_processing/pip_engine.py

@@ -18,22 +18,13 @@ from pathlib import Path
 
 # 向后兼容：POSITION_BOTTOM_CENTER 也从 pip_config 再导出
 from packages.domain.pip_config import POSITION_BOTTOM_CENTER  # noqa: E402, F401
+from packages.domain.pip_config import PiPConfig  # noqa: F401
 from packages.domain.pip_config import (
     ANIMATION_FADE,
-    ANIMATION_SCALE,
     ANIMATION_SLIDE_BOTTOM,
     ANIMATION_SLIDE_LEFT,
     ANIMATION_SLIDE_RIGHT,
     ANIMATION_SLIDE_TOP,
-    POSITION_BOTTOM_LEFT,
-    POSITION_BOTTOM_RIGHT,
-    POSITION_CENTER,
-    POSITION_CENTER_LEFT,
-    POSITION_CENTER_RIGHT,
-    POSITION_TOP_CENTER,
-    POSITION_TOP_LEFT,
-    POSITION_TOP_RIGHT,
-    PiPConfig,
     PiPLayerConfig,
 )
 from packages.domain.pip_config import (  # noqa: F401 — 向后兼容：保留模块级导出

apps/worker/video_processing/render_subtitles.py

@@ -13,9 +13,6 @@ from pathlib import Path
 from typing import Any
 
 from packages.domain.ass_subtitle_builder import (
-    TITLE_MARGIN_BOTTOM,
-    TITLE_MARGIN_SIDE,
-    TITLE_MARGIN_TOP,
     build_ass_content,
 )
 from packages.domain.ass_subtitle_builder import build_ass_style as _build_ass_style_base  # noqa: F401 — 向后兼容

apps/worker/video_processing/sticker_engine.py

@@ -14,16 +14,20 @@ import logging
 from pathlib import Path
 from typing import Any
 
+# isort: off
 from packages.domain.sticker_config import (
-    POSITION_PRESETS,
-    STICKER_CATEGORIES,
+    POSITION_PRESETS,  # noqa: F401
+    STICKER_CATEGORIES,  # noqa: F401
     ImageStickerConfig,
     StickerOverlayResult,
     TextStickerConfig,
 )
-from packages.domain.sticker_config import get_sticker_categories as _get_sticker_categories_base  # noqa: F401  向后兼容导出
+from packages.domain.sticker_config import (
+    get_sticker_categories as _get_sticker_categories_base,
+)  # noqa: F401  向后兼容导出
 from packages.domain.sticker_config import parse_stickers_from_config as _parse_stickers_base
 from packages.domain.sticker_config import (
+    # isort: on
     resolve_sticker_position,
 )
 

apps/worker/video_processing/subtitle_render_engine.py

@@ -25,28 +25,22 @@ from __future__ import annotations
 
 import logging
 from pathlib import Path
+from typing import Any
 
 from video_processing.path_security import PathSecurityError, is_in_allowed_dirs, safe_resolve_path
 
 from packages.domain.subtitle_style import (
     ALLOWED_SUBTITLE_EXTENSIONS,
-    DEFAULT_COLOR,
-    DEFAULT_FONT,
     DEFAULT_FONT_SIZE,
-    DEFAULT_MAX_CHARS_PER_LINE,
     DEFAULT_POSITION,
-    DEFAULT_STROKE_COLOR,
-    DEFAULT_STROKE_WIDTH,
-    POSITION_ALIASES,
-    POSITION_ALIGNMENT,
     SubtitleSegment,
     SubtitleStyle,
 )
 from packages.domain.subtitle_style import escape_ass_text as _escape_ass_text  # noqa: F401  向后兼容导出
 from packages.domain.subtitle_style import format_ass_time as _format_ass_time
-from packages.domain.subtitle_style import hex_to_ass_bgr as _hex_to_ass_bgr
-from packages.domain.subtitle_style import hex_to_ass_color as _hex_to_ass_color
-from packages.domain.subtitle_style import opacity_to_ass_alpha as _opacity_to_ass_alpha
+from packages.domain.subtitle_style import hex_to_ass_bgr as _hex_to_ass_bgr  # noqa: F401
+from packages.domain.subtitle_style import hex_to_ass_color as _hex_to_ass_color  # noqa: F401
+from packages.domain.subtitle_style import opacity_to_ass_alpha as _opacity_to_ass_alpha  # noqa: F401
 from packages.domain.subtitle_style import wrap_text as _wrap_text
 
 logger = logging.getLogger(__name__)

apps/worker/video_processing/trim_engine.py

@@ -15,16 +15,14 @@ from __future__ import annotations
 import logging
 from typing import Any
 
+from packages.domain.trim_config import MIN_TRIM_DURATION  # noqa: F401
+from packages.domain.trim_config import extract_trim_from_clip_config  # noqa: F401
 from packages.domain.trim_config import (
-    MIN_TRIM_DURATION,
     TrimConfig,
     TrimSegment,
 )
 from packages.domain.trim_config import build_audio_trim_filter as _build_audio_trim_filter  # noqa: F401 — 向后兼容
 from packages.domain.trim_config import build_video_trim_filter as _build_video_trim_filter
-from packages.domain.trim_config import (
-    extract_trim_from_clip_config,
-)
 from packages.domain.trim_config import parse_segments_from_config as _parse_segments_from_config
 from packages.domain.trim_config import resolve_segments as _resolve_segments
 

apps/worker/video_processing/unified_render_service.py

@@ -53,7 +53,6 @@ from video_processing.tts_engine import TtsEngine
 from video_processing.watermark_engine import WatermarkConfig, WatermarkEngine
 
 from packages.domain.render_layer_utils import LAYER_Z_INDEX as _IMPORTED_LAYER_Z_INDEX
-from packages.domain.render_layer_utils import can_pass_through as _can_pass_through_pure
 from packages.domain.render_layer_utils import clip_adjusted_duration as _clip_adjusted_duration_pure
 from packages.domain.render_layer_utils import clip_effective_duration as _clip_effective_duration_pure
 from packages.domain.render_layer_utils import clip_playback_speed as _clip_playback_speed_pure

apps/worker/video_processing/watermark_engine.py

@@ -14,10 +14,9 @@
 from __future__ import annotations
 
 import logging
-from typing import Any
 
+from packages.domain.watermark_config import WATERMARK_POSITIONS  # noqa: F401
 from packages.domain.watermark_config import (
-    WATERMARK_POSITIONS,
     WatermarkConfig,
 )
 from packages.domain.watermark_config import (  # noqa: F401 — 向后兼容

packages/domain/pip_config.py

@@ -186,7 +186,7 @@ class PiPConfig:
         """最大 z_index."""
         if not self.layers:
             return 0
-        return max(l.z_index for l in self.layers)
+        return max(layer.z_index for layer in self.layers)
 
 
 # ── 纯逻辑工具函数 ───────────────────────────────────────────────────────────

packages/domain/subtitle_style.py

@@ -6,7 +6,7 @@
 
 from __future__ import annotations
 
-from dataclasses import dataclass, field
+from dataclasses import dataclass
 from typing import Any
 
 # ── 常量 ──────────────────────────────────────────────────────────────────────

packages/domain/trim_config.py

@@ -11,7 +11,7 @@
 from __future__ import annotations
 
 import logging
-from dataclasses import dataclass, field
+from dataclasses import dataclass
 from typing import Any
 
 logger = logging.getLogger(__name__)

packages/domain/watermark_config.py

@@ -10,7 +10,7 @@
 from __future__ import annotations
 
 import logging
-from dataclasses import dataclass, field
+from dataclasses import dataclass
 from typing import Any
 
 logger = logging.getLogger(__name__)

tests/unit/test_color_grade_config.py

@@ -39,7 +39,7 @@ class TestConstants:
 
     def test_preset_params_complete(self):
         assert set(PRESET_PARAMS.keys()) == VALID_PRESETS
-        for preset, params in PRESET_PARAMS.items():
+        for _preset, params in PRESET_PARAMS.items():
             assert set(params.keys()) == set(ALL_PARAM_KEYS)
 
     def test_default_params_keys(self):
@@ -54,7 +54,7 @@ class TestConstants:
             assert min_val <= DEFAULT_PARAMS[key] <= max_val
 
     def test_all_presets_within_ranges(self):
-        for preset, params in PRESET_PARAMS.items():
+        for _preset, params in PRESET_PARAMS.items():
             for key in ALL_PARAM_KEYS:
                 min_val, max_val = PARAM_RANGES[key]
                 assert min_val <= params[key] <= max_val, f"{preset}.{key}={params[key]} out of range"

tests/unit/test_pip_config.py

@@ -208,7 +208,7 @@ class TestPiPConfigFromDict:
             }
         )
         assert cfg.layer_count == 3
-        assert [l.source for l in cfg.layers] == ["bottom", "mid", "top"]
+        assert [layer.source for layer in cfg.layers] == ["bottom", "mid", "top"]
 
     def test_invalid_layer_skipped(self):
         cfg = PiPConfig.from_dict(

tests/unit/test_sticker_config.py

@@ -23,7 +23,7 @@ class TestConstants:
         assert len(POSITION_PRESETS) == 9
 
     def test_position_presets_normalized(self):
-        for name, (x, y) in POSITION_PRESETS.items():
+        for _name, (x, y) in POSITION_PRESETS.items():
             assert 0.0 <= x <= 1.0
             assert 0.0 <= y <= 1.0