chronaxis.batch.process_transport
传递独立计划快照和小型结果，保留工作进程中的失败清理责任。
管道仅连接本次创建的可信子进程，不读取外部序列化对象。计划重建后核对身份， 大型结果在子进程内写出并关闭。清理失败的进程暂停接活，由报告句柄远程重试。
这是模块参考。日常调用先查公开API索引；下划线对象和嵌套函数供维护者查阅。签名来自固定源码，公开类构造签名经实际Python接口核对。
相关类型
AnalysisPlan、BatchJob、BatchJobResult、CleanupHandle、ControlChannel、Path、ProcessTree
对象导航
| 对象 | 用途 |
|---|---|
job_packet |
提取无活动资源的计划。 |
restore_job |
恢复独立计划。 |
ProcessWorker |
保存一个可复用工作进程、私有管道及其后代的清理责任。 |
ProcessWorker.__init__ |
启动等待命令的spawn进程。 |
ProcessWorker.submit |
发送独立任务。 |
ProcessWorker.submit_fast |
只传准备完成的文件参数，工作进程不重新解析模板或建立下层进程。 |
ProcessWorker.cancel_fast |
通知在途文件，协作退出超过五秒才结束本次拥有的进程树。返回是否已强制回收。 |
ProcessWorker.ready |
查询结果或异常退出。 |
ProcessWorker.receive |
取结果并挂远程恢复句柄。 |
ProcessWorker.close |
先重试待办远程清理，再关闭本次工作进程树、启动管道和进程句柄；重复调用从尚未完成的阶段继续。 |
导入与重导出来源（展开）
from dataclasses import replace
from pathlib import Path
from time import monotonic
from ..planning.plan import AnalysisPlan
from ..planning.checks import json_value
from .._control_wire import ControlChannel
from ..results.budget import _cleanup_owner
from .models import BatchJob, BatchJobResult, CleanupHandle
from .process_tree import ProcessTree
from .._process_start import spawn_entry
from .._batch_worker import worker_mainjob_packet
提取无活动资源的计划。
job_packet(job)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
job |
BatchJob | 是 | 无 | 位置或关键字。本次独立任务；提取路径或原生配置快照，不传递运行资源。 |
返回说明
原生dict。
异常说明
配置转换错误。
源码：src/chronaxis/batch/process_transport.py:22（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
restore_job
恢复独立计划。
restore_job(packet)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
packet |
dict | 是 | 无 | 位置或关键字。本批由job_packet产生的声明；路径模式保延迟加载，内存模式重建后核对identity。 |
返回说明
BatchJob。
异常说明
重建或身份不一致。
源码：src/chronaxis/batch/process_transport.py:30（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
ProcessWorker
保存一个可复用工作进程、私有管道及其后代的清理责任。
ProcessWorker(*, fast=False)源码：src/chronaxis/batch/process_transport.py:40（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
ProcessWorker.__init__
启动等待命令的spawn进程。
ProcessWorker.__init__(*, fast=False)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
fast |
bool | 否 | False | 仅关键字。启用 fast 的共享取消信号和文件级任务协议。 |
返回说明
新对象。
异常说明
启动/树登记失败立即回收。
源码：src/chronaxis/batch/process_transport.py:43（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
ProcessWorker.submit
发送独立任务。
ProcessWorker.submit(job, directory, backend)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
job |
BatchJob | 是 | 无 | 位置或关键字。本次待运行的独立任务；发送其路径或不可变配置快照，不传递活跃文件或结果对象。 |
directory |
pathlib.Path | 是 | 无 | 位置或关键字。该任务独占的输出根目录，不能复用其他任务目录。 |
backend |
str | None | 是 | 无 | 位置或关键字。本批可选计算实现覆盖：None沿用任务配置，reference或numpy使用对应实现。 |
返回说明
None。
异常说明
转换或通信错误。
源码：src/chronaxis/batch/process_transport.py:82（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
ProcessWorker.submit_fast
只传准备完成的文件参数，工作进程不重新解析模板或建立下层进程。
ProcessWorker.submit_fast(job, directory, spec, total)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
job |
BatchJob | 是 | 无 | 位置或关键字。待派发的独立文件任务，其名称进入报告。 |
directory |
Path | 是 | 无 | 位置或关键字。给本次任务独占的结果目录。 |
spec |
dict | 是 | 无 | 位置或关键字。一个文件的已绑定参数，包括 DBC、通道、数值公式和输出单位。 |
total |
bool | 是 | 无 | 位置或关键字。是否回传未舍入指标，供同一模板的成员按输入顺序相加。 |
源码：src/chronaxis/batch/process_transport.py:86（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
ProcessWorker.cancel_fast
通知在途文件，协作退出超过五秒才结束本次拥有的进程树。返回是否已强制回收。
ProcessWorker.cancel_fast()参数：无显式参数。
源码：src/chronaxis/batch/process_transport.py:92（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
ProcessWorker.ready
查询结果或异常退出。
ProcessWorker.ready()参数：无显式参数。
参数说明
无。
返回说明
bool。
异常说明
管道探测或进程状态检查发生 EOFError 或 OSError 时抛出 ChildProcessError，携带工作进程 PID 并保留原异常。探测时确认 EOF 或断管后，关闭阶段跳过远程握手。
源码：src/chronaxis/batch/process_transport.py:103（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
ProcessWorker.receive
取结果并挂远程恢复句柄。
ProcessWorker.receive()参数：无显式参数。
参数说明
无。
返回说明
BatchJobResult。
异常说明
探测不到结果，或探测、读取遇到 EOF 或断管时，抛出带工作进程 PID 的 ChildProcessError。已收到的消息仍按正常协议校验，类型或种类不符报 RuntimeError，解包失败原样传播。
源码：src/chronaxis/batch/process_transport.py:112（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
ProcessWorker.close
先重试待办远程清理，再关闭本次工作进程树、启动管道和进程句柄；重复调用从尚未完成的阶段继续。
ProcessWorker.close()参数：无显式参数。
参数说明
无。
返回说明
None。
异常说明
远程清理未成功时抛 RuntimeError；Linux 清理回复超时、关闭协议未完成或断管进程未退出时抛 TimeoutError。系统资源关闭错误原样传播。失败保留尚未释放的对象与已完成步骤，后续 close 可重试；不会重新运行任务。
处理流程说明
管道可用时先处理待办清理，再发送关闭命令。已知断管时关闭本次 ProcessTree；没有已登记的进程树时只终止本对象实际持有的工作进程。Linux 通过已确认的 pidfd 进程组结束同组后代，Windows 通过作业对象回收后代。Linux 的清理回复、关闭等待，以及断管后的退出等待均有五秒边界；Windows 正常关闭仍沿用原等待行为。最后关闭本次启动管道、业务端点和 Process 句柄。
源码：src/chronaxis/batch/process_transport.py:133（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。