From d18458eb794ae7f2928865fcf2c862228e3cf8fb Mon Sep 17 00:00:00 2001 From: huangruiteng Date: Sat, 5 Sep 2026 02:51:50 +0800 Subject: [PATCH] fix(authority): keep event lookup inside control plane Signed-off-by: huangruiteng --- .../coordination/local_authority_shadow_adapter.py | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/loopx/control_plane/coordination/local_authority_shadow_adapter.py b/loopx/control_plane/coordination/local_authority_shadow_adapter.py index 1bed5207a3..639206e43a 100644 --- a/loopx/control_plane/coordination/local_authority_shadow_adapter.py +++ b/loopx/control_plane/coordination/local_authority_shadow_adapter.py @@ -687,11 +687,16 @@ def _read_state_text(path: Path) -> str: def _event_present(sources: _GoalSources, event_id: str) -> bool: from ...event_sourced_state import AppendOnlyStateEventStore - from ...status import state_event_log_candidates + from ..goals.active_state_event_projection import state_event_log_candidates + from ..goals.path_resolution import resolve_goal_local_path if sources.goal is None: return False - for candidate in state_event_log_candidates(sources.goal, state_path=sources.state_path): + for candidate in state_event_log_candidates( + sources.goal, + state_path=sources.state_path, + resolve_goal_local_path=resolve_goal_local_path, + ): if not candidate.exists(): continue for event in AppendOnlyStateEventStore(candidate).load():