chronaxis.execution.record_sequences
收齐同一时刻的请求、响应和条件后配对,直接交付最终结果。
只保留本次输入组之前的有限条件边界及尚待响应的请求。没有配对请求时不 建立本对象;不会为配对保存整段信号历史或另一时间轴。每个规则的观测终点 由其必要来源决定,响应来源提前结束只使后续响应未知,不提前结束其他来源。
这是模块参考。日常调用先查公开API索引;下划线对象和嵌套函数供维护者查阅。签名来自固定源码,公开类构造签名经实际Python接口核对。
相关类型
BudgetExceededError、ConditionTick、IntervalChoice、QualityFlag(源码别名Q)、ResultClosedError、SequenceDetector、SequenceRule、SequenceTick、T
对象导航
| 对象 | 用途 |
|---|---|
RecordSequences |
拥有同一时刻合并队列及FIFO候选;计划、状态和结果消费者为借用。 |
RecordSequences.__init__ |
登记有限配对配置。 |
RecordSequences._open |
拒绝失败实例。 |
RecordSequences._entry |
先付费再建立一组。 |
RecordSequences.bounds |
从真实来源范围开始/收窄配对域,在末组交付之前调用。 |
RecordSequences.observe |
借用规则批时先付费再保留必要点,不保存不参与配对的规则。 |
RecordSequences.drivers |
仅记录配对实际需要的驱动更新身份。 |
RecordSequences._consume |
一次提交同一时刻A/B,候选到结果交付完毕才退费。 |
RecordSequences.flush_before |
所有规则已交付边界后,按实际时间处理一次;None仅用于真实全体EOF。 |
RecordSequences.closed |
返回资源关闭状态。 |
RecordSequences.close |
放弃未发布候选并退还自有费用。 |
导入与重导出来源(展开)
from ..planning.intervals import IntervalChoice
from dataclasses import replace
from ..core.sequence import SequenceRule, SequenceTick
from ..core.sequence_reference import SequenceDetector
from ..core.temporal import ConditionTick
from ..core.types import Truth as T, QualityFlag as Q
from ..results.errors import ResultClosedError, BudgetExceededError
from ..results.spool import _reserve_owned_ram, _release_owned_ram, _cleanup_owner
from .history import _metadata_bytesRecordSequences
拥有同一时刻合并队列及FIFO候选;计划、状态和结果消费者为借用。
RecordSequences(plan, state, budget, steps, consumer)源码:src/chronaxis/execution/record_sequences.py:19(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSequences.__init__
登记有限配对配置。
RecordSequences.__init__(plan, state, budget, steps, consumer)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
plan |
AnalysisPlan | 是 | 无 | 位置或关键字。已完成静态解析的分析计划,包含来源、绑定、规则、指标、间隔选择和输出要求。 |
state |
LatestSignalState | 是 | 无 | 位置或关键字。当前会话各依赖信号的最新有效状态;过期按实际时间判断,不能跨独立任务继承。 |
budget |
ResourceBudget | 是 | 无 | 位置或关键字。本次分析共享的资源用量记录;新对象先预约所需内存和磁盘额度,关闭时归还自己的内存费用。 |
steps |
Mapping[str, int | None] | 是 | 无 | 位置或关键字。节点id到已解析周期的映射;None为实际间隔,正整数为固定或DBC纳秒周期。 |
consumer |
Callable[[SequenceResult], None] | 是 | 无 | 位置或关键字。接收当前请求完成的配对或超时判定,不收集未请求的输入历史。 |
返回说明
owner。
异常说明
构造原错附owner。
源码:src/chronaxis/execution/record_sequences.py:22(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSequences._open
拒绝失败实例。
RecordSequences._open()参数:无显式参数。
参数说明
无。
返回说明
None。
异常说明
ResultClosedError。
源码:src/chronaxis/execution/record_sequences.py:36(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSequences._entry
先付费再建立一组。
RecordSequences._entry(time_ns)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
time_ns |
int | 是 | 无 | 位置或关键字。本次操作对应的实际时刻,单位纳秒;必须按输入的单调顺序推进,不是累计的固定周期数。 |
返回说明
可变组。
异常说明
预算原错。
源码:src/chronaxis/execution/record_sequences.py:41(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSequences.bounds
从真实来源范围开始/收窄配对域,在末组交付之前调用。
RecordSequences.bounds(cursors, ends)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
cursors |
Sequence[RecordSourceCursor] | 是 | 无 | 位置或关键字。本次实际打开的来源游标,借用其真实首末时刻和EOF状态;调用方保留关闭责任。 |
ends |
Mapping[str, int] | 是 | 无 | 位置或关键字。来源名到已知实际EOF纳秒时刻的映射,用于收尾和裁剪。 |
返回说明
None。
异常说明
范围/预算错误。
源码:src/chronaxis/execution/record_sequences.py:48(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSequences.observe
借用规则批时先付费再保留必要点,不保存不参与配对的规则。
RecordSequences.observe(rule, tick, events)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
rule |
str | 是 | 无 | 位置或关键字。当前条件点和事件所属的规则ID,只处理配对实际依赖的规则。 |
tick |
ConditionTick | 是 | 无 | 位置或关键字。一个完整实际时刻的条件真/假/未知状态,包含质量及终点标志。 |
events |
tuple[Event, ...] | 是 | 无 | 位置或关键字。当前实际时刻产生的事件集合;同一时刻事件先收齐再交给配对处理。 |
返回说明
None。
异常说明
预算/重复点错误。
源码:src/chronaxis/execution/record_sequences.py:92(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSequences.drivers
仅记录配对实际需要的驱动更新身份。
RecordSequences.drivers(group)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
group |
DecodedTimeGroup | 是 | 无 | 位置或关键字。同一实际时刻收齐的所需信号更新;本组全部到齐后再求值,避免来源遍历顺序影响结果。 |
返回说明
None。
异常说明
预算错误。
源码:src/chronaxis/execution/record_sequences.py:108(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSequences._consume
一次提交同一时刻A/B,候选到结果交付完毕才退费。
RecordSequences._consume(time_ns, entry, active)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
time_ns |
int | 是 | 无 | 位置或关键字。本次操作对应的实际时刻,单位纳秒;必须按输入的单调顺序推进,不是累计的固定周期数。 |
entry |
list | 是 | 无 | 位置或关键字。待提交同一时刻组的内部容器,依次保存规则点/事件映射、更新驱动集合和已付预算字节数。 |
active |
list | 是 | 无 | 位置或关键字。当前配对检测状态,依次为声明、检测器、上一条件、是否已有驱动及是否结束。 |
返回说明
None。
异常说明
原计算错。
源码:src/chronaxis/execution/record_sequences.py:117(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSequences.flush_before
所有规则已交付边界后,按实际时间处理一次;None仅用于真实全体EOF。
RecordSequences.flush_before(before=None)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
before |
int | None | 否 | None | 位置或关键字。仅提交早于该实际纳秒时刻的待处理组;None提交全部已排队组。 |
返回说明
None。
异常说明
原错并封闭实例。
源码:src/chronaxis/execution/record_sequences.py:163(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSequences.closed
返回资源关闭状态。
RecordSequences.closed装饰器:property。
读取属性,不使用调用括号。
参数说明
无。
返回说明
bool。
异常说明
无。
源码:src/chronaxis/execution/record_sequences.py:188(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
RecordSequences.close
放弃未发布候选并退还自有费用。
RecordSequences.close()参数:无显式参数。
参数说明
无。
返回说明
None。
异常说明
预算释放原错可重试。
源码:src/chronaxis/execution/record_sequences.py:192(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。