services.init_service
源文件
services/init_service.py· 由scripts/gen_api_docs.py自动生成,请勿手改
模块说明:
初始化流程控制器 — 状态管理 + 进度信号 + 重试/跳过
用法(CLI): from services.init_service import InitService service = InitService() asyncio.run(service.run_all())
用法(GUI): service = InitService() service.step_progress.connect(on_progress) service.start()
函数
_noop
def _noop(*args, **kwargs)⚠️ 待补 docstring
此函数暂无 docstring,欢迎补充。
定义行:94
is_step_satisfied
def is_step_satisfied(step_key: str) -> bool检查某步骤是否已就绪(数据是否存在)
定义行:101
get_missing_steps
def get_missing_steps() -> list[InitStep]返回所有未就绪的步骤(check_all 只跑一次,避免 8 次重复查询)
定义行:109
类
class InitStep
单个初始化步骤的元信息
定义行:39
class StepStatus(继承 Enum)
⚠️ 待补 docstring
此类暂无 docstring,欢迎补充。
定义行:49
class InitService(继承 QObject)
初始化流程控制器
信号(GUI 模式): step_started(key, name) step_progress(key, percent, message) step_completed(key, success, message) all_completed(success, summary) network_status(ok, message)
回调(CLI 模式): on_step_started(key, name) on_step_progress(key, percent, message) on_step_completed(key, success, message) on_all_completed(success, summary)
定义行:122
方法
__init__
def __init__(self, parent: QObject | None=None)⚠️ 待补 docstring
此函数暂无 docstring,欢迎补充。
定义行:146
start
def start(self, step_keys: list[str] | None=None)开始初始化
定义行:170
retry
def retry(self, step_key: str)重试单个失败步骤
定义行:194
retry_all_failed
def retry_all_failed(self)重试所有失败步骤
定义行:202
skip
def skip(self, step_key: str) -> bool跳过非关键步骤。返回 True 表示跳过成功。
定义行:212
cancel
def cancel(self)取消当前执行:所有未完成步骤(含等待依赖的)置 CANCELLED。
定义行:225
get_status
def get_status(self) -> dict[str, StepStatus]返回所有步骤的当前状态
定义行:239
get_errors
def get_errors(self) -> dict[str, str]返回所有失败步骤的错误消息
定义行:243
reset
def reset(self)重置所有步骤为 PENDING
定义行:247
check_network
async def check_network(self) -> bool检查 ESI 连通性(带重试:网络抖动/慢响应不误判为不可用)。
定义行:259
_run_sequence
async def _run_sequence(self, keys: list[str])按依赖图并行执行步骤列表。
定义行:289
_run_one
async def _run_one(self, key: str)单个步骤任务:等依赖 → 网络检查 → 执行 → 上报(可并行运行)
定义行:331
_ensure_net_once
async def _ensure_net_once(self) -> bool网络检查单飞:并发请求合并为一次 check_network,结果共享。
定义行:395
_prepare_ref_db_for_parallel
def _prepare_ref_db_for_parallel()并行前准备 reference.db:WAL + 长 busy_timeout。
定义行:402
_deps_satisfied
def _deps_satisfied(self, step: InitStep) -> bool检查前置步骤是否已完成。
定义行:422
_run_step
async def _run_step(self, key: str) -> tuple[bool, str]实际执行一个初始化步骤
定义行:440
_inject_progress_callback
def _inject_progress_callback(self, key: str)设置进度回调环境变量(给 write_progress 使用)
定义行:507
_emit_step_started
def _emit_step_started(self, key: str, name: str)⚠️ 待补 docstring
此函数暂无 docstring,欢迎补充。
定义行:516
_emit_step_progress
def _emit_step_progress(self, key: str, percent: int, message: str)⚠️ 待补 docstring
此函数暂无 docstring,欢迎补充。
定义行:523
_emit_step_completed
def _emit_step_completed(self, key: str, success: bool, message: str)⚠️ 待补 docstring
此函数暂无 docstring,欢迎补充。
定义行:530
_emit_all_completed
def _emit_all_completed(self, success: bool, summary: str)⚠️ 待补 docstring
此函数暂无 docstring,欢迎补充。
定义行:537
_emit_network
def _emit_network(self, ok: bool, message: str)⚠️ 待补 docstring
此函数暂无 docstring,欢迎补充。
定义行:544