Skip to content

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 ​

python
def _noop(*args, **kwargs)

⚠️ 待补 docstring

此函数暂无 docstring,欢迎补充。

定义行:94

is_step_satisfied ​

python
def is_step_satisfied(step_key: str) -> bool

检查某步骤是否已就绪(数据是否存在)

定义行:101

get_missing_steps ​

python
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__ ​
python
def __init__(self, parent: QObject | None=None)

⚠️ 待补 docstring

此函数暂无 docstring,欢迎补充。

定义行:146

start ​
python
def start(self, step_keys: list[str] | None=None)

开始初始化

定义行:170

retry ​
python
def retry(self, step_key: str)

重试单个失败步骤

定义行:194

retry_all_failed ​
python
def retry_all_failed(self)

重试所有失败步骤

定义行:202

skip ​
python
def skip(self, step_key: str) -> bool

跳过非关键步骤。返回 True 表示跳过成功。

定义行:212

cancel ​
python
def cancel(self)

取消当前执行:所有未完成步骤(含等待依赖的)置 CANCELLED。

定义行:225

get_status ​
python
def get_status(self) -> dict[str, StepStatus]

返回所有步骤的当前状态

定义行:239

get_errors ​
python
def get_errors(self) -> dict[str, str]

返回所有失败步骤的错误消息

定义行:243

reset ​
python
def reset(self)

重置所有步骤为 PENDING

定义行:247

check_network ​
python
async def check_network(self) -> bool

检查 ESI 连通性(带重试:网络抖动/慢响应不误判为不可用)。

定义行:259

_run_sequence ​
python
async def _run_sequence(self, keys: list[str])

按依赖图并行执行步骤列表。

定义行:289

_run_one ​
python
async def _run_one(self, key: str)

单个步骤任务:等依赖 → 网络检查 → 执行 → 上报(可并行运行)

定义行:331

_ensure_net_once ​
python
async def _ensure_net_once(self) -> bool

网络检查单飞:并发请求合并为一次 check_network,结果共享。

定义行:395

_prepare_ref_db_for_parallel ​
python
def _prepare_ref_db_for_parallel()

并行前准备 reference.db:WAL + 长 busy_timeout。

定义行:402

_deps_satisfied ​
python
def _deps_satisfied(self, step: InitStep) -> bool

检查前置步骤是否已完成。

定义行:422

_run_step ​
python
async def _run_step(self, key: str) -> tuple[bool, str]

实际执行一个初始化步骤

定义行:440

_inject_progress_callback ​
python
def _inject_progress_callback(self, key: str)

设置进度回调环境变量(给 write_progress 使用)

定义行:507

_emit_step_started ​
python
def _emit_step_started(self, key: str, name: str)

⚠️ 待补 docstring

此函数暂无 docstring,欢迎补充。

定义行:516

_emit_step_progress ​
python
def _emit_step_progress(self, key: str, percent: int, message: str)

⚠️ 待补 docstring

此函数暂无 docstring,欢迎补充。

定义行:523

_emit_step_completed ​
python
def _emit_step_completed(self, key: str, success: bool, message: str)

⚠️ 待补 docstring

此函数暂无 docstring,欢迎补充。

定义行:530

_emit_all_completed ​
python
def _emit_all_completed(self, success: bool, summary: str)

⚠️ 待补 docstring

此函数暂无 docstring,欢迎补充。

定义行:537

_emit_network ​
python
def _emit_network(self, ok: bool, message: str)

⚠️ 待补 docstring

此函数暂无 docstring,欢迎补充。

定义行:544