Chronaxis用户手册English
本页目录相关类型对象导航RecordSessionCalculationsRecordSessionCalculations.__init__RecordSessionCalculations._newRecordSessionCalculations._consume_groupRecordSessionCalculations._emit_selectionRecordSessionCalculations._emit_input_traceRecordSessionCalculations._emit_contributionRecordSessionCalculations.execute_intoRecordSessionCalculations._prepare_requestsRecordSessionCalculations._prepare_input_stateRecordSessionCalculations._prepare_operatorsRecordSessionCalculations._complete_resultsRecordSessionCalculations._append_aggregate_inputRecordSessionCalculations._finish_actual_tailsRecordSessionCalculations._consume_constantsRecordSessionCalculations._emit_eventRecordSessionCalculations._emit_event_durationRecordSessionCalculations._emit_segmentRecordSessionCalculations._count_outcomeRecordSessionCalculations.analysis_outcomeRecordSessionCalculations.threshold_summariesRecordSessionCalculations._emit_sequenceRecordSessionCalculations._consume_messageRecordSessionCalculations._flush_messagesRecordSessionCalculations._consume_direct_updateRecordSessionCalculations._before_direct_groupRecordSessionCalculations._advance_observed_domainRecordSessionCalculations._merge_sourcesRecordSessionCalculations._close_slotRecordSessionCalculations._require_closedRecordSessionCalculations.close

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

对象导航

对象 用途
RecordSessionCalculations 拥有实时计算和读取子资源;计划与最终结果仓只借用。
RecordSessionCalculations.__init__ 预约有限声明空间,不启动读取。
RecordSessionCalculations._new 保留尚未交付的真实子owner。
RecordSessionCalculations._consume_group 先原子提交同一时刻组,再分别按所选报文推进各指标。
RecordSessionCalculations._emit_selection 按请求保存一份选择值及状态。
RecordSessionCalculations._emit_input_trace 仅按trace请求写最终追溯表。
RecordSessionCalculations._emit_contribution 仅按请求写计算定位和值/跳过。
RecordSessionCalculations.execute_into 准备输入与算子,推进一次输入,并把已完成结果写入原结果仓。
RecordSessionCalculations._prepare_requests 从已验证计划取得请求和间隔选择;只为实际输出建立汇总状态。
RecordSessionCalculations._prepare_input_state 按共用需求打开来源并建立最新信号状态,不提前读完文件。
RecordSessionCalculations._prepare_operators 依次建立实际请求的计算、事件、窗口和序列算子。
RecordSessionCalculations._complete_results 输入真正EOF后完成尾部、统计和结果汇总,不发布未完成前缀。
RecordSessionCalculations._append_aggregate_input 从同一源行同时得到公开记录和聚合输入,不复制或重扫源表。
RecordSessionCalculations._finish_actual_tails 以实际来源EOF结算连续计算和样本统计,固定周期不凭空加报文。
RecordSessionCalculations._consume_constants 常量只需真实首末范围,EOF后复用相同统计核,不创建假信号或逐行值。
RecordSessionCalculations._emit_event 将必要事件字段直接写一次最终结果仓。
RecordSessionCalculations._emit_event_duration 把每段事件指标直接写最终指标表。
RecordSessionCalculations._emit_segment 只写实际片段与父关联,后续指标借用同一片段。
RecordSessionCalculations._count_outcome 随已写出的指标计数。
RecordSessionCalculations.analysis_outcome 取得同次规则和指标概况。
RecordSessionCalculations.threshold_summaries 生成明确预设请求的有限汇总,不复制状态轨迹。
RecordSessionCalculations._emit_sequence 只写最终配对结论,不复制事件全文。
RecordSessionCalculations._consume_message 按原序收集有限目标批,供同来源各累计器共用。
RecordSessionCalculations._flush_messages 共享当前目标批完成各汇总计算,不创建历史或逐次输出。
RecordSessionCalculations._consume_direct_update 向已完成首帧前检查的同帧owner交付更新。
RecordSessionCalculations._before_direct_group 结算前更新省略domain的实际范围;显式裁剪不额外查询。
RecordSessionCalculations._advance_observed_domain 用已付费游标的真实首末更新在线范围,不读取更多输入或保存时间序列。
RecordSessionCalculations._merge_sources 每来源只取已付费前瞻,收齐同一时刻更新再求值。
RecordSessionCalculations._close_slot 关闭成功才解除责任。
RecordSessionCalculations._require_closed 核实子资源真实关闭再撤槽。
RecordSessionCalculations.close 反向释放自有资源,保留失败槽供父会话重试。
导入与重导出来源(展开)
python
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 SummarySelectionRow

RecordSessionCalculations

拥有实时计算和读取子资源;计划与最终结果仓只借用。

python
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__

预约有限声明空间,不启动读取。

python
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。

python
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

先原子提交同一时刻组,再分别按所选报文推进各指标。

python
RecordSessionCalculations._consume_group(group)

参数

名称 数据类型 必填 省略时的值 用途、取值和效果
group DecodedTimeGroup 是 无 位置或关键字。同一实际时刻收齐的所需信号更新;本组全部到齐后再求值,避免来源遍历顺序影响结果。

返回说明

None。

异常说明

表达式/预算/累计原错。 非驱动无效更新仅截断待算值,不新增周期;条件截止独立处理。

源码:src/chronaxis/execution/record_session_calculations.py:123(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。

RecordSessionCalculations._emit_selection

按请求保存一份选择值及状态。

python
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请求写最终追溯表。

python
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

仅按请求写计算定位和值/跳过。

python
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

准备输入与算子,推进一次输入,并把已完成结果写入原结果仓。

python
RecordSessionCalculations.execute_into(spool)

参数

名称 数据类型 必填 省略时的值 用途、取值和效果
spool ResultSpool 是 无 位置或关键字。接收或读取本次最终结果的有界暂存;不重新读取原始日志。

返回说明

None,不在这里发布文件。

异常说明

原始准备、读取或计算错误;保留可重试的record_session_cleanup_owner。

源码:src/chronaxis/execution/record_session_calculations.py:217(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。

RecordSessionCalculations._prepare_requests

从已验证计划取得请求和间隔选择;只为实际输出建立汇总状态。

python
RecordSessionCalculations._prepare_requests(spool)

参数

名称 数据类型 必填 省略时的值 用途、取值和效果
spool chronaxis.results.spool.ResultSpool 是 无 位置或关键字。当前会话借用的结果仓,由调用方持有;本阶段只追加或封存已完成结果,不接管关闭责任。

返回说明

会话数值请求与间隔选择。

异常说明

汇总状态构造错误。

源码:src/chronaxis/execution/record_session_calculations.py:245(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。

RecordSessionCalculations._prepare_input_state

按共用需求打开来源并建立最新信号状态,不提前读完文件。

python
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

依次建立实际请求的计算、事件、窗口和序列算子。

python
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后完成尾部、统计和结果汇总,不发布未完成前缀。

python
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

从同一源行同时得到公开记录和聚合输入,不复制或重扫源表。

python
RecordSessionCalculations._append_aggregate_input(row)

参数

名称 数据类型 必填 省略时的值 用途、取值和效果
row SummaryCalculationRow 是 无 位置或关键字。已生成的会话或父范围指标行,连同身份、数值和质量送给订阅它的结果聚合器。

返回说明

None。

异常说明

原写出/归约错误终止整个会话。

源码:src/chronaxis/execution/record_session_calculations.py:551(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。

RecordSessionCalculations._finish_actual_tails

以实际来源EOF结算连续计算和样本统计,固定周期不凭空加报文。

python
RecordSessionCalculations._finish_actual_tails()

参数:无显式参数。

参数说明

无,读取已耗尽游标、最新状态及尚待结算的末点。

返回说明

None。

异常说明

表达式、预算或累计错误原样传播。 不新增样本、贡献或追溯;观察结束和TTL都来自真实输入,domain仅负责裁剪。

源码:src/chronaxis/execution/record_session_calculations.py:559(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。

RecordSessionCalculations._consume_constants

常量只需真实首末范围,EOF后复用相同统计核,不创建假信号或逐行值。

python
RecordSessionCalculations._consume_constants()

参数:无显式参数。

参数说明

无。

返回说明

None。

异常说明

求值/预算/计算原错;无观测不喂任何点。

源码:src/chronaxis/execution/record_session_calculations.py:598(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。

RecordSessionCalculations._emit_event

将必要事件字段直接写一次最终结果仓。

python
RecordSessionCalculations._emit_event(event)

参数

名称 数据类型 必填 省略时的值 用途、取值和效果
event Event 是 无 位置或关键字。本次规则产生的活动或点事件;保留实际开始、确认、结束和状态。

返回说明

None。

异常说明

原写入错。

源码:src/chronaxis/execution/record_session_calculations.py:621(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。

RecordSessionCalculations._emit_event_duration

把每段事件指标直接写最终指标表。

python
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

只写实际片段与父关联,后续指标借用同一片段。

python
RecordSessionCalculations._emit_segment(segment)

参数

名称 数据类型 必填 省略时的值 用途、取值和效果
segment CompactSegment 是 无 位置或关键字。已确定的实际窗口片段,包含业务范围及父事件关联,供计算或导出使用。

返回说明

None。

异常说明

原发布/计算错。

源码:src/chronaxis/execution/record_session_calculations.py:650(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。

RecordSessionCalculations._count_outcome

随已写出的指标计数。

python
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

取得同次规则和指标概况。

python
RecordSessionCalculations.analysis_outcome()

参数:无显式参数。

参数说明

无。

返回说明

AnalysisOutcome。

异常说明

规则未完成。

源码:src/chronaxis/execution/record_session_calculations.py:672(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。

RecordSessionCalculations.threshold_summaries

生成明确预设请求的有限汇总,不复制状态轨迹。

python
RecordSessionCalculations.threshold_summaries()

参数:无显式参数。

参数说明

无。

返回说明

tuple。

异常说明

未完成统计错误。

源码:src/chronaxis/execution/record_session_calculations.py:677(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。

RecordSessionCalculations._emit_sequence

只写最终配对结论,不复制事件全文。

python
RecordSessionCalculations._emit_sequence(result)

参数

名称 数据类型 必填 省略时的值 用途、取值和效果
result SequenceResult 是 无 位置或关键字。一次请求的配对或超时判定,关联原事件并保留所选计时依据下的延迟。

返回说明

None。

异常说明

原写入错。

源码:src/chronaxis/execution/record_session_calculations.py:690(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。

RecordSessionCalculations._consume_message

按原序收集有限目标批,供同来源各累计器共用。

python
RecordSessionCalculations._consume_message(update)

参数

名称 数据类型 必填 省略时的值 用途、取值和效果
update LegacyDecodedUpdate 是 无 位置或关键字。当前一条所需报文更新,保留原输入序号、所需字段和有效状态;同一时刻不同报文仍分别处理。

返回说明

None。

异常说明

预算、计算或取消原错;完整明细仍逐消息交付。

源码:src/chronaxis/execution/record_session_calculations.py:702(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。

RecordSessionCalculations._flush_messages

共享当前目标批完成各汇总计算,不创建历史或逐次输出。

python
RecordSessionCalculations._flush_messages()

参数:无显式参数。

参数说明

无,使用已付费的有限消息缓冲。

返回说明

None。

异常说明

原计算/取消错误优先;清理失败保留费用,供close重试。

源码:src/chronaxis/execution/record_session_calculations.py:743(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。

RecordSessionCalculations._consume_direct_update

向已完成首帧前检查的同帧owner交付更新。

python
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的实际范围;显式裁剪不额外查询。

python
RecordSessionCalculations._before_direct_group() -> None

参数:无显式参数。

参数说明

无。

返回说明

None。

异常说明

原读取状态错误。

返回类型:None。

源码:src/chronaxis/execution/record_session_calculations.py:775(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。

RecordSessionCalculations._advance_observed_domain

用已付费游标的真实首末更新在线范围,不读取更多输入或保存时间序列。

python
RecordSessionCalculations._advance_observed_domain()

参数:无显式参数。

参数说明

无。

返回说明

None。显式范围保持原裁剪规则;省略范围只保一个当前并集。

异常说明

非法时间或已封闭检测器的推进错误沿原清理路径传播。

源码:src/chronaxis/execution/record_session_calculations.py:783(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。

RecordSessionCalculations._merge_sources

每来源只取已付费前瞻,收齐同一时刻更新再求值。

python
RecordSessionCalculations._merge_sources()

参数:无显式参数。

参数说明

无。

返回说明

None,所有实际来源EOF才返回。

异常说明

原读取/计算/预算错误。 不按文件顺序拼接不同来源,不为跨源合并建磁盘历史。

源码:src/chronaxis/execution/record_session_calculations.py:815(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。

RecordSessionCalculations._close_slot

关闭成功才解除责任。

python
RecordSessionCalculations._close_slot(slot)

参数

名称 数据类型 必填 省略时的值 用途、取值和效果
slot str 是 无 位置或关键字。资源拥有者中登记句柄的属性名;关闭成功才清空该槽,失败保留以便重试。

返回说明

None。

异常说明

原关闭错,槽保留以便重试。

源码:src/chronaxis/execution/record_session_calculations.py:877(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。

RecordSessionCalculations._require_closed

核实子资源真实关闭再撤槽。

python
RecordSessionCalculations._require_closed(owner)

装饰器:staticmethod。

参数

名称 数据类型 必填 省略时的值 用途、取值和效果
owner 具备close()和closed属性的资源对象 是 无 位置或关键字。本次已登记的子资源;关闭失败保留对象供重试,不清理外部资源。

返回说明

None。

异常说明

AnalysisError保留原责任。

源码:src/chronaxis/execution/record_session_calculations.py:886(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。

RecordSessionCalculations.close

反向释放自有资源,保留失败槽供父会话重试。

python
RecordSessionCalculations.close()

参数:无显式参数。

参数说明

无。

返回说明

None。

异常说明

原关闭/预算错误;不会抵销其他owner的费用。

源码:src/chronaxis/execution/record_session_calculations.py:891(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。

Chronaxis 用户手册 · 离线阅读