Method startChildRetryClaimed

packages/runtime/src/runtime-kernel.ts:1225–1448

(
    sessionId: string,
    input: ChildAgentRetryInput,
    execution: PendingExecutionClaim,
  )

  }

  private async *startChildRetryClaimed(
    sessionId: string,
    input: ChildAgentRetryInput,
    execution: PendingExecutionClaim,
  ): AsyncIterable<SessionEvent> {
    const continuation = snapshotRuntimeContinuation(input.continuation);
    await this.enterExecutionClaim(execution);
    if (continuation.sessionId !== sessionId) {
      throw new Error('Child retry continuation belongs to a different session');
    }
    const parentHeader = await this.deps.store.readHeader(sessionId);
    const linkedSnapshot = input.linkedSession ? parentHeader.subagentRuntime : undefined;
    if (
      input.linkedSession &&
      (parentHeader.subagentParent?.kind !== 'subagent' ||
        !linkedSnapshot ||
        linkedSnapshot.agentId !== input.spec.id)
    ) {
      throw new Error('Linked child retry is missing its durable runtime snapshot');
    }
    const definition = linkedSnapshot
      ? {
          id: linkedSnapshot.agentId,
          name: linkedSnapshot.agentName,
          systemPrompt: linkedSnapshot.systemPrompt,
          permissionMode: parentHeader.permissionMode,
          tools: linkedSnapshot.toolNames,
        }
      : requireBuiltinAgentDefinition(input.spec.id);
    const availableChildTools = this.deps.childTools ?? [];
    if (!linkedSnapshot) {
      assertAgentDefinitionRunnable({
        definition: requireBuiltinAgentDefinition(input.spec.id),
        tools: availableChildTools,
      });
    }
    const childTools = buildToolsForAgentDefinition(availableChildTools, definition);
    if (linkedSnapshot && childTools.length !== linkedSnapshot.toolNames.length) {
      throw new Error('Linked child retry durable runtime tool snapshot is unavailable');
    }
    const childHeader: SessionHeader = linkedSnapshot
      ? parentHeader
      : {
          ...parentHeader,
          permissionMode: definition.permissionMode,
          connectionLocked: true,
        };
    const userInput: UserMessageInput = {
      turnId: continuation.turnId,
      text: '',
      ...(!linkedSnapshot ? { parentRunId: input.parentRunId } : {}),
      retriedFromRunId: continuation.sourceRunId,
      agentId: definition.id,
      agentName: definition.name,
    };
    const effectiveOrchestration = resolveEffectiveOrchestration('default', undefined);
    if (!this.deps.runStore || !this.deps.runtimeEventStore) {
      throw new Error('Child retry continuation requires AgentRunStore and RuntimeEventStore');