1 oracle.pipelines.evaluated_rollout

oracle.pipelines.evaluated_rollout

Join replay transitions with pipeline-local Oracle outputs.

This module provides adapters from Oracle candidate evaluations to replay policy scores while retaining typed evidence sidecars for later Zarr materialization.

1.1 Classes

Name Description
EvaluatedRollout Replay result joined to Oracle outputs by chain and step index.
EvaluatedRolloutRecord Evaluated rollout plus lineage consumed by the Zarr writer.
EvaluatedRolloutStep A replay transition joined to its compact Oracle evaluation.
OracleReplayAdapter Project Oracle evaluations while preserving complete selected history.
OracleReplayInvalidityError Pipeline control flow carrying a typed Oracle invalidity outcome.

1.1.1 EvaluatedRollout

oracle.pipelines.evaluated_rollout.EvaluatedRollout(result, steps=dict())

Replay result joined to Oracle outputs by chain and step index.

1.1.1.1 Methods

Name Description
step Return the evaluated step for one retained chain position.
1.1.1.1.1 step
oracle.pipelines.evaluated_rollout.EvaluatedRollout.step(chain_id, step_index)

Return the evaluated step for one retained chain position.

1.1.2 EvaluatedRolloutRecord

oracle.pipelines.evaluated_rollout.EvaluatedRolloutRecord(
    evaluated,
    lineage,
    rollout_id_prefix,
)

Evaluated rollout plus lineage consumed by the Zarr writer.

1.1.3 EvaluatedRolloutStep

oracle.pipelines.evaluated_rollout.EvaluatedRolloutStep(transition, evaluation)

A replay transition joined to its compact Oracle evaluation.

1.1.4 OracleReplayAdapter

oracle.pipelines.evaluated_rollout.OracleReplayAdapter(
    scorer,
    *,
    selected_observation_provider=None,
    selection_observer=None,
)

Project Oracle evaluations while preserving complete selected history.

Optional selected_observation_provider receives the original candidate object and compact hard-valid row. Its validated full-scene depth and raw world cloud are resolved lazily before successor scoring, then for every retained final action during materialize. Cache identity includes the selected row so sibling branches never share a different observation. Cropped scorer outputs are rejected without a provider; default full-scene outputs reuse their existing candidate cloud without another acquisition.

selection_observer receives the actual replay transition, unmodified complete evaluation and optional full acquisition once per selected action. It is intended for bounded validation capture, not policy modification. Completion/error releases borrowed caches; materialized tensors retain their ownership independently of this adapter.

1.1.4.1 Methods

Name Description
materialize Join cached Oracle outputs to retained replay chains.
clear Release borrowed candidate tables and selected observations after completion/error.
1.1.4.1.1 materialize
oracle.pipelines.evaluated_rollout.OracleReplayAdapter.materialize(
    result,
    *,
    retain_target_crops,
)

Join cached Oracle outputs to retained replay chains.

1.1.4.1.2 clear
oracle.pipelines.evaluated_rollout.OracleReplayAdapter.clear()

Release borrowed candidate tables and selected observations after completion/error.

1.1.5 OracleReplayInvalidityError

oracle.pipelines.evaluated_rollout.OracleReplayInvalidityError(invalidity)

Pipeline control flow carrying a typed Oracle invalidity outcome.

Back to top