const started = Date.now();

const startupStages = createEmbeddedRunStageTracker();

let startupStagesEmitted = false;

const notifyExecutionPhase = (

phase: Parameters<NonNullable<RunEmbeddedPiAgentParams["onExecutionPhase"]>>[0]["phase"],

extra?: Omit<

Parameters<NonNullable<RunEmbeddedPiAgentParams["onExecutionPhase"]>>[0],

"phase"

>,

) => {

params.onExecutionPhase?.({ phase, ...extra });

};

const emitStartupStageSummary = (phase: string) => {

const summary = startupStages.snapshot();

const shouldWarn = shouldWarnEmbeddedRunStageSummary(summary);

}

};

params.onExecutionStarted?.();

notifyExecutionPhase("runner_entered");

const workspaceResolution = resolveRunWorkspaceDir({

workspaceDir: params.workspaceDir,

sessionKey: params.sessionKey,

);

}

startupStages.mark("workspace");

notifyExecutionPhase("workspace");

ensureRuntimePluginsLoaded({

config: params.config,

workspaceDir: resolvedWorkspace,

allowGatewaySubagentBinding: params.allowGatewaySubagentBinding,

});

startupStages.mark("runtime-plugins");

notifyExecutionPhase("runtime_plugins");

let provider = (params.provider ?? DEFAULT_PROVIDER).trim() || DEFAULT_PROVIDER;

let modelId = (params.model ?? DEFAULT_MODEL).trim() || DEFAULT_MODEL;

const ctxInfo = resolvedRuntimeModel.ctxInfo;

let effectiveModel = resolvedRuntimeModel.effectiveModel;

startupStages.mark("model-resolution");

notifyExecutionPhase("model_resolution", { provider, model: modelId });

const authStore = pluginHarnessOwnsTransport

? createEmptyAuthProfileStore()

lastProfileId = forwardedPluginHarnessProfileId;

}

startupStages.mark("auth");

notifyExecutionPhase("auth", { provider, model: modelId });

const runAttemptAuthProfileStore = pluginHarnessOwnsTransport

? createScopedAuthProfileStore(attemptAuthProfileStore, lastProfileId)

: attemptAuthProfileStore;

});

const contextEnginePluginId = resolveContextEngineOwnerPluginId(contextEngine);

startupStages.mark("context-engine");

notifyExecutionPhase("context_engine", { provider, model: modelId });

try {

const resolveActiveHookContext = () => ({

...hookCtx,

});

if (!startupStagesEmitted) {

startupStages.mark("attempt-dispatch");

notifyExecutionPhase("attempt_dispatch", { provider, model: modelId });

emitStartupStageSummary("attempt-dispatch");

startupStagesEmitted = true;

}