Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 5 additions & 1 deletion loopx/control_plane/runtime/runtime_projection_route.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
goal_activation_state,
normalize_goal_activation_state,
)
from ...history import load_index, load_registry
from ..projects.registry_codec import load_registry
from ... import paths
from ...paths import global_registry_path, resolve_runtime_root
from ...registry import registry_goals
Expand Down Expand Up @@ -451,6 +451,8 @@ def _latest_route_source_row(
goal_id: str,
route_id: str,
) -> dict[str, Any] | None:
from ...history import load_index

rows, _ = load_index(runtime_root / "goals" / goal_id / "runs" / "index.jsonl")
for row in reversed(rows):
marker = row.get("runtime_projection_route")
Expand All @@ -471,6 +473,8 @@ def _route_projection_is_current(
source_generated_at: Any,
marker_field: str,
) -> bool:
from ...history import load_index

rows, _ = load_index(
target_runtime_root / "goals" / goal_id / "runs" / "index.jsonl"
)
Expand Down
Loading