refactor: skip judge logic improvement
This commit is contained in:
@@ -1370,20 +1370,11 @@ class EventLoopNode(NodeProtocol):
|
||||
if not should_judge:
|
||||
# Gap C: unjudged iteration — log as CONTINUE
|
||||
_continue_count += 1
|
||||
if ctx.runtime_logger:
|
||||
iter_latency_ms = int((time.time() - iter_start) * 1000)
|
||||
ctx.runtime_logger.log_step(
|
||||
node_id=node_id,
|
||||
node_type="event_loop",
|
||||
step_index=iteration,
|
||||
verdict="CONTINUE",
|
||||
verdict_feedback="Unjudged (judge_every_n_turns skip)",
|
||||
tool_calls=logged_tool_calls,
|
||||
llm_text=assistant_text,
|
||||
input_tokens=turn_tokens.get("input", 0),
|
||||
output_tokens=turn_tokens.get("output", 0),
|
||||
latency_ms=iter_latency_ms,
|
||||
)
|
||||
self._log_skip_judge(
|
||||
ctx, node_id, iteration,
|
||||
"Unjudged (judge_every_n_turns skip)",
|
||||
logged_tool_calls, assistant_text, turn_tokens, iter_start,
|
||||
)
|
||||
continue
|
||||
|
||||
# Judge evaluation (should_judge is always True here)
|
||||
|
||||
@@ -838,7 +838,7 @@ def register_queen_lifecycle_tools(
|
||||
"""Send a message to the running worker agent.
|
||||
|
||||
Injects the message into the worker's active node conversation.
|
||||
Use this to relay user instructions or concerns to the worker.
|
||||
Use this to relay user instructions to the worker.
|
||||
"""
|
||||
runtime = _get_runtime()
|
||||
if runtime is None:
|
||||
|
||||
Reference in New Issue
Block a user