中断与恢复

resume_iteration = interruption_state.iteration
logger.info(f"Resuming ReAct from iteration {resume_iteration + 1}")

# Step 1: record feedback for the current pending workflow
pending_wf_id = interruption_state.pending_workflow_id
pending_comp_id = interruption_state.pending_component_id

# ...（1760-1800 行：补记反馈、重放已完成工作流、检查是否再次中断）

# All workflows completed — continue ReAct loop from next iteration
ctx.extra[RESUME_START_ITERATION_KEY] = resume_iteration + 1

/**
 * Continue an agent loop from the current context without adding a new message.
 * Used for retries - context already has user message or tool results.
 *
 * **Important:** The last message in context must convert to a `user` or `toolResult` message
 * via `convertToLlm`. If it doesn't, the LLM provider will reject the request.
 * This cannot be validated here since `convertToLlm` is only called once per turn.
 */
export function agentLoopContinue(
	context: AgentContext,
	config: AgentLoopConfig,
	signal: AbortSignal | undefined,
	streamFn: StreamFn,
): EventStream<AgentEvent, AgentMessage[]> {
	if (context.messages.length === 0) {
		throw new Error("Cannot continue: no messages in context");
	}

	if (context.messages[context.messages.length - 1].role === "assistant") {
		throw new Error("Cannot continue from message role: assistant");
	}