chronaxis.execution.record_session_calculations
在原AnalysisRunner会话内合并所需来源并执行会话时间指标。
共享同一时刻最新状态;每项指标只保自己的驱动点和归约状态。输入只读一次, 不创建普通历史、消息历史或完整贡献。均值仅保其算法必需的值与权重暂存。 每来源只保有界前瞻,同一时刻跨来源更新收齐后求值。所有输入真正EOF并关闭 后才交付最终结果,失败不发布已累计的前缀。
这是模块参考。日常调用先查公开API索引;下划线对象和嵌套函数供维护者查阅。签名来自固定源码,公开类构造签名经实际Python接口核对。
相关类型
AnalysisError、AnalysisOutcome、CalculationDefinition、CurrentMessageCalculation、DecodedTimeGroup、DriverExpression、Interval、IntervalChoice、LatestSignalState、LegacySkipReason、QualityFlag(源码别名Q)、RecordDiagnostics、RecordEventDurations、RecordExports、RecordIntegral、RecordRuleTimeline、RecordScopeCalculations、RecordSelection、RecordSequences、RecordSourceCursor、RecordTimeCalculation、RecordTimeIndexes、RecordWindows、ResultClosedError、SummaryCalculationRow、SummaryContributionRow、SummaryCoverageCalculationRow、SummaryEventRow、SummaryHostedCalculationRow、SummaryInputRow、SummarySegmentRow、SummarySelectionRow、SummarySequenceRow
对象导航
导入与重导出来源(展开)
from ..core.moments import SAMPLE_MOMENTS
from ..core.quantiles import SAMPLE_QUANTILES
from dataclasses import replace
from ..core.models import Interval
from functools import partial
from ..core.calculations import CalculationDefinition
from ..legacy.records import field_to_dict
from ..results.errors import ResultClosedError, AnalysisError
from ..results.spool import _reserve_owned_ram, _release_owned_ram, _cleanup_owner
from ..results.summary import SummaryCalculationRow
from ..results.summary import SummaryCoverageCalculationRow, SummaryHostedCalculationRow
from ..results.summary import SummaryEventRow
from ..core.types import QualityFlag as Q
from ..results.summary import SummarySequenceRow
from ..sources.can_spec import can_field_from_key
from .history import _metadata_bytes
from .state import LatestSignalState
from .driver_expression import DriverExpression
from .record_integral import RecordIntegral
from .record_time_calculation import RecordTimeCalculation
from .record_source_cursor import RecordSourceCursor
from .groups import DecodedTimeGroup
from .current_message_calculation import CurrentMessageCalculation
from ..legacy.sum import LegacySkipReason
from .record_rule_timeline import RecordRuleTimeline
from .record_sequences import RecordSequences
from ..planning.intervals import IntervalChoice
from .record_event_durations import RecordEventDurations, is_event_duration
from ..core.counts_v4 import OBJECT_COUNTS
from .record_object_counts import object_count_results
from .record_scope_calculations import RecordScopeCalculations
from .record_time_indexes import RecordTimeIndexes
from .record_windows import RecordWindows
from .record_exports import RecordExports
from ..results.summary import SummarySegmentRow
from ..results.summary import SummaryContributionRow
from ..results.summary import SummaryInputRow
from .record_diagnostics import RecordDiagnostics
from .record_selection import RecordSelection
from ..results.summary import SummarySelectionRowRecordSessionCalculations
拥有实时计算和读取子资源;计划与最终结果仓只借用。
RecordSessionCalculations(plan, budget, work_dir, *, requirements=None, declaration_owner=None, direct_integrals: bool=False)源码:src/chronaxis/execution/record_session_calculations.py:51(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations.__init__
预约有限声明空间,不启动读取。
RecordSessionCalculations.__init__(plan, budget, work_dir, *, requirements=None, declaration_owner=None, direct_integrals: bool=False)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
plan |
AnalysisPlan | 是 | 无 | 位置或关键字。已完成静态解析的分析计划,包含来源、绑定、规则、指标、间隔选择和输出要求。 |
budget |
ResourceBudget | 是 | 无 | 位置或关键字。本次分析共享的资源用量记录;新对象先预约所需内存和磁盘额度,关闭时归还自己的内存费用。 |
work_dir |
str | Path | None | 是 | 无 | 位置或关键字。本次专用工作目录,用于确实需要的临时资源;使用新目录,不能覆盖已有内容。目录名称不限,是否可省略由本表签名默认值明确给出。 |
requirements |
InputRequirements | SourceInputRequirements | 否 | None | 仅关键字。需求分析所得的当前任务或单来源输入范围,用来跳过没有消费者的值、时间和历史。 |
declaration_owner |
RunSession | None | 否 | None | 仅关键字。持有共享声明的父运行会话。仅接受同一账本中仍开放的实际owner;省略时状态独立计入声明费用。 |
direct_integrals |
bool | 否 | False | 仅关键字。仅内部auto候选启用直接积分检查;False使用原通用流程,不是用户免检开关。 |
返回说明
新owner。
异常说明
构造原错附record_session_cleanup_owner供父会话接管。
源码:src/chronaxis/execution/record_session_calculations.py:54(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations._new
保留尚未交付的真实子owner。
RecordSessionCalculations._new(factory, recovery, *args, **kwargs)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
factory |
Callable | 是 | 无 | 位置或关键字。要调用的资源构造器;失败时按recovery取回真实拥有者,不吞掉原始异常。 |
recovery |
str | 是 | 无 | 位置或关键字。构造异常上用于取回未返回资源拥有者的属性名,确保失败后仍能关闭和退款。 |
args |
tuple | 否 | () | 可变位置。传给factory的位置参数,保持原有参数顺序。 |
kwargs |
dict | 否 | {} | 可变关键字。传给factory的关键字参数,保持原有名称与值。 |
返回说明
owner。
异常说明
原错。
源码:src/chronaxis/execution/record_session_calculations.py:115(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations._consume_group
先原子提交同一时刻组,再分别按所选报文推进各指标。
RecordSessionCalculations._consume_group(group)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
group |
DecodedTimeGroup | 是 | 无 | 位置或关键字。同一实际时刻收齐的所需信号更新;本组全部到齐后再求值,避免来源遍历顺序影响结果。 |
返回说明
None。
异常说明
表达式/预算/累计原错。 非驱动无效更新仅截断待算值,不新增周期;条件截止独立处理。
源码:src/chronaxis/execution/record_session_calculations.py:123(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations._emit_selection
按请求保存一份选择值及状态。
RecordSessionCalculations._emit_selection(request, parent, row)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
request |
CalculationPlan | 是 | 无 | 位置或关键字。当前指标请求,包含ID、统计范围、算子、表达式和缺失处理政策。 |
parent |
str | None | 是 | 无 | 位置或关键字。当前结果关联的事件或片段ID;会话级结果使用None。 |
row |
SelectionRow | 是 | 无 | 位置或关键字。样本选择内核给出的一条结果,保留实际时间、业务值和真/未知选择状态。 |
返回说明
None。
异常说明
暂存错误。
源码:src/chronaxis/execution/record_session_calculations.py:191(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations._emit_input_trace
仅按trace请求写最终追溯表。
RecordSessionCalculations._emit_input_trace(source, sequence, time_ns, record_type, locator, values, quality)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
source |
str | 是 | 无 | 位置或关键字。当前结果或记录所属的来源名称,必须对应计划中已经定义的source。 |
sequence |
int | 是 | 无 | 位置或关键字。当前记录的非负顺序号;同一时刻记录仍有独立序号,不能当作时间戳。 |
time_ns |
int | None | 是 | 无 | 位置或关键字。当前记录的实际纳秒时刻;仅明确不需要采集时间的输入诊断可为None。 |
record_type |
str | 是 | 无 | 位置或关键字。输入记录种类:decoded_message表示所需报文解码值,signal_sample表示普通信号值,signal_clock表示只保留更新时间的记录。 |
locator |
str | 是 | 无 | 位置或关键字。当前报文或字段的非空定位文本,配合来源和原记录序号定位所需输入。 |
values |
str | 是 | 无 | 位置或关键字。已经规范化的所需输入值JSON文本;直接写最终追溯行,不再重复编码整份输入。 |
quality |
QualityFlag | 是 | 无 | 位置或关键字。该值或结果的质量位组合;缺失、过期等原因不能通过清零掩盖。 |
返回说明
None。
异常说明
暂存错误。
源码:src/chronaxis/execution/record_session_calculations.py:200(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations._emit_contribution
仅按请求写计算定位和值/跳过。
RecordSessionCalculations._emit_contribution(request, contribution, quality)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
request |
MessageCalculationPlan | 是 | 无 | 位置或关键字。产生该贡献的逐消息指标声明,提供结果身份、单位和分桶政策。 |
contribution |
LegacySumContribution | 是 | 无 | 位置或关键字。一次分别用每条消息中的值计算表达式或跳过的结果,不附完整原帧和原值副本。 |
quality |
QualityFlag | 是 | 无 | 位置或关键字。本次贡献的质量位,写入对应结果行;不能因结果值存在而清除已观察到的质量问题。 |
返回说明
None。
异常说明
暂存原错。
源码:src/chronaxis/execution/record_session_calculations.py:207(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations.execute_into
准备输入与算子,推进一次输入,并把已完成结果写入原结果仓。
RecordSessionCalculations.execute_into(spool)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
spool |
ResultSpool | 是 | 无 | 位置或关键字。接收或读取本次最终结果的有界暂存;不重新读取原始日志。 |
返回说明
None,不在这里发布文件。
异常说明
原始准备、读取或计算错误;保留可重试的record_session_cleanup_owner。
源码:src/chronaxis/execution/record_session_calculations.py:217(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations._prepare_requests
从已验证计划取得请求和间隔选择;只为实际输出建立汇总状态。
RecordSessionCalculations._prepare_requests(spool)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
spool |
chronaxis.results.spool.ResultSpool | 是 | 无 | 位置或关键字。当前会话借用的结果仓,由调用方持有;本阶段只追加或封存已完成结果,不接管关闭责任。 |
返回说明
会话数值请求与间隔选择。
异常说明
汇总状态构造错误。
源码:src/chronaxis/execution/record_session_calculations.py:245(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations._prepare_input_state
按共用需求打开来源并建立最新信号状态,不提前读完文件。
RecordSessionCalculations._prepare_input_state(choices)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
choices |
dict[str, chronaxis.planning.intervals.IntervalChoice] | 是 | 无 | 位置或关键字。计算或规则标识对应的已解析间隔选择;包含实际、固定或 DBC 周期及所选推进信号。 |
返回说明
实际定义、来源游标映射和状态。
异常说明
来源、DBC周期或资源构造错误;子资源立即登记到本会话。
源码:src/chronaxis/execution/record_session_calculations.py:274(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations._prepare_operators
依次建立实际请求的计算、事件、窗口和序列算子。
RecordSessionCalculations._prepare_operators(session_values, choices, definitions, source_cursors, state)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
session_values |
tuple[chronaxis.planning.models.CalculationPlan, ...] | 是 | 无 | 位置或关键字。实际请求的会话数值计算,顺序对应已建立的归约对象;不包含单独处理的对象计数。 |
choices |
dict[str, chronaxis.planning.intervals.IntervalChoice] | 是 | 无 | 位置或关键字。计算或规则标识对应的已解析间隔选择;包含实际、固定或 DBC 周期及所选推进信号。 |
definitions |
tuple[chronaxis.core.binding.SignalDefinition, ...] | 是 | 无 | 位置或关键字。当前分析实际使用并已解析有效期的信号定义。 |
source_cursors |
dict[str, chronaxis.execution.record_source_cursor.RecordSourceCursor] | 是 | 无 | 位置或关键字。来源名称到本次读取游标的映射,提供实际输入状态及所需 DBC 周期元数据。 |
state |
chronaxis.execution.state.LatestSignalState | 是 | 无 | 位置或关键字。本会话共享的最新完整同一时刻组状态;算子借用它,不单独读取原始文件。 |
返回说明
None。
异常说明
单位、周期或资源构造错误,已构造对象仍由本会话持有。
源码:src/chronaxis/execution/record_session_calculations.py:377(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations._complete_results
输入真正EOF后完成尾部、统计和结果汇总,不发布未完成前缀。
RecordSessionCalculations._complete_results(session_values, spool)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
session_values |
tuple[chronaxis.planning.models.CalculationPlan, ...] | 是 | 无 | 位置或关键字。实际请求的会话数值计算,顺序对应已建立的归约对象;不包含单独处理的对象计数。 |
spool |
chronaxis.results.spool.ResultSpool | 是 | 无 | 位置或关键字。当前会话借用的结果仓,由调用方持有;本阶段只追加或封存已完成结果,不接管关闭责任。 |
返回说明
None。
异常说明
尾部计算、封存或写入错误。
源码:src/chronaxis/execution/record_session_calculations.py:503(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations._append_aggregate_input
从同一源行同时得到公开记录和聚合输入,不复制或重扫源表。
RecordSessionCalculations._append_aggregate_input(row)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
row |
SummaryCalculationRow | 是 | 无 | 位置或关键字。已生成的会话或父范围指标行,连同身份、数值和质量送给订阅它的结果聚合器。 |
返回说明
None。
异常说明
原写出/归约错误终止整个会话。
源码:src/chronaxis/execution/record_session_calculations.py:551(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations._finish_actual_tails
以实际来源EOF结算连续计算和样本统计,固定周期不凭空加报文。
RecordSessionCalculations._finish_actual_tails()参数:无显式参数。
参数说明
无,读取已耗尽游标、最新状态及尚待结算的末点。
返回说明
None。
异常说明
表达式、预算或累计错误原样传播。 不新增样本、贡献或追溯;观察结束和TTL都来自真实输入,domain仅负责裁剪。
源码:src/chronaxis/execution/record_session_calculations.py:559(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations._consume_constants
常量只需真实首末范围,EOF后复用相同统计核,不创建假信号或逐行值。
RecordSessionCalculations._consume_constants()参数:无显式参数。
参数说明
无。
返回说明
None。
异常说明
求值/预算/计算原错;无观测不喂任何点。
源码:src/chronaxis/execution/record_session_calculations.py:598(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations._emit_event
将必要事件字段直接写一次最终结果仓。
RecordSessionCalculations._emit_event(event)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
event |
Event | 是 | 无 | 位置或关键字。本次规则产生的活动或点事件;保留实际开始、确认、结束和状态。 |
返回说明
None。
异常说明
原写入错。
源码:src/chronaxis/execution/record_session_calculations.py:621(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations._emit_event_duration
把每段事件指标直接写最终指标表。
RecordSessionCalculations._emit_event_duration(request, event_id, result)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
request |
CalculationPlan | 是 | 无 | 位置或关键字。当前指标请求,包含ID、统计范围、算子、表达式和缺失处理政策。 |
event_id |
str | 是 | 无 | 位置或关键字。本次事件的稳定id,用于指标、窗口及配对结果引用。 |
result |
RecordTimeResult | 是 | 无 | 位置或关键字。事件时长计算的数值、单位、质量及完整/部分/未知状态。 |
返回说明
None。
异常说明
原发布错。
源码:src/chronaxis/execution/record_session_calculations.py:636(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations._emit_segment
只写实际片段与父关联,后续指标借用同一片段。
RecordSessionCalculations._emit_segment(segment)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
segment |
CompactSegment | 是 | 无 | 位置或关键字。已确定的实际窗口片段,包含业务范围及父事件关联,供计算或导出使用。 |
返回说明
None。
异常说明
原发布/计算错。
源码:src/chronaxis/execution/record_session_calculations.py:650(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations._count_outcome
随已写出的指标计数。
RecordSessionCalculations._count_outcome(status, reason)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
status |
str | 是 | 无 | 位置或关键字。已经写出的计算行状态,限complete、partial或indeterminate;对应概况计数加1。 |
reason |
str | None | 是 | 无 | 位置或关键字。该计算行的实际原因;no_observation或no_evaluations额外计入无观测行数,其余原因不增加该项。 |
返回说明
None。
异常说明
未支持的内部状态。
源码:src/chronaxis/execution/record_session_calculations.py:666(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations.analysis_outcome
取得同次规则和指标概况。
RecordSessionCalculations.analysis_outcome()参数:无显式参数。
参数说明
无。
返回说明
AnalysisOutcome。
异常说明
规则未完成。
源码:src/chronaxis/execution/record_session_calculations.py:672(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations.threshold_summaries
生成明确预设请求的有限汇总,不复制状态轨迹。
RecordSessionCalculations.threshold_summaries()参数:无显式参数。
参数说明
无。
返回说明
tuple。
异常说明
未完成统计错误。
源码:src/chronaxis/execution/record_session_calculations.py:677(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations._emit_sequence
只写最终配对结论,不复制事件全文。
RecordSessionCalculations._emit_sequence(result)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
result |
SequenceResult | 是 | 无 | 位置或关键字。一次请求的配对或超时判定,关联原事件并保留所选计时依据下的延迟。 |
返回说明
None。
异常说明
原写入错。
源码:src/chronaxis/execution/record_session_calculations.py:690(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations._consume_message
按原序收集有限目标批,供同来源各累计器共用。
RecordSessionCalculations._consume_message(update)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
update |
LegacyDecodedUpdate | 是 | 无 | 位置或关键字。当前一条所需报文更新,保留原输入序号、所需字段和有效状态;同一时刻不同报文仍分别处理。 |
返回说明
None。
异常说明
预算、计算或取消原错;完整明细仍逐消息交付。
源码:src/chronaxis/execution/record_session_calculations.py:702(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations._flush_messages
共享当前目标批完成各汇总计算,不创建历史或逐次输出。
RecordSessionCalculations._flush_messages()参数:无显式参数。
参数说明
无,使用已付费的有限消息缓冲。
返回说明
None。
异常说明
原计算/取消错误优先;清理失败保留费用,供close重试。
源码:src/chronaxis/execution/record_session_calculations.py:743(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations._consume_direct_update
向已完成首帧前检查的同帧owner交付更新。
RecordSessionCalculations._consume_direct_update(update: 'LegacyDecodedUpdate') -> None参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
update |
LegacyDecodedUpdate | 是 | 无 | 位置或关键字。原读取器和投影器已经验证的本条解码更新;无效新值也必须交付。 |
返回说明
None。
异常说明
原消费错误。
返回类型:None。
源码:src/chronaxis/execution/record_session_calculations.py:771(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations._before_direct_group
结算前更新省略domain的实际范围;显式裁剪不额外查询。
RecordSessionCalculations._before_direct_group() -> None参数:无显式参数。
参数说明
无。
返回说明
None。
异常说明
原读取状态错误。
返回类型:None。
源码:src/chronaxis/execution/record_session_calculations.py:775(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations._advance_observed_domain
用已付费游标的真实首末更新在线范围,不读取更多输入或保存时间序列。
RecordSessionCalculations._advance_observed_domain()参数:无显式参数。
参数说明
无。
返回说明
None。显式范围保持原裁剪规则;省略范围只保一个当前并集。
异常说明
非法时间或已封闭检测器的推进错误沿原清理路径传播。
源码:src/chronaxis/execution/record_session_calculations.py:783(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations._merge_sources
每来源只取已付费前瞻,收齐同一时刻更新再求值。
RecordSessionCalculations._merge_sources()参数:无显式参数。
参数说明
无。
返回说明
None,所有实际来源EOF才返回。
异常说明
原读取/计算/预算错误。 不按文件顺序拼接不同来源,不为跨源合并建磁盘历史。
源码:src/chronaxis/execution/record_session_calculations.py:815(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations._close_slot
关闭成功才解除责任。
RecordSessionCalculations._close_slot(slot)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
slot |
str | 是 | 无 | 位置或关键字。资源拥有者中登记句柄的属性名;关闭成功才清空该槽,失败保留以便重试。 |
返回说明
None。
异常说明
原关闭错,槽保留以便重试。
源码:src/chronaxis/execution/record_session_calculations.py:877(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations._require_closed
核实子资源真实关闭再撤槽。
RecordSessionCalculations._require_closed(owner)装饰器:staticmethod。
参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
owner |
具备close()和closed属性的资源对象 | 是 | 无 | 位置或关键字。本次已登记的子资源;关闭失败保留对象供重试,不清理外部资源。 |
返回说明
None。
异常说明
AnalysisError保留原责任。
源码:src/chronaxis/execution/record_session_calculations.py:886(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSessionCalculations.close
反向释放自有资源,保留失败槽供父会话重试。
RecordSessionCalculations.close()参数:无显式参数。
参数说明
无。
返回说明
None。
异常说明
原关闭/预算错误;不会抵销其他owner的费用。
源码:src/chronaxis/execution/record_session_calculations.py:891(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。