From 0ba2a2eb279af063b7d3a80d4d7971b40f4f42cd Mon Sep 17 00:00:00 2001
From: Altay <altay@uinaf.dev>
Date: Mon, 9 Mar 2026 21:33:56 +0300
Subject: [PATCH] Agents: clarify failover observation input types

---
 .../pi-embedded-runner/run/failover-observation.ts | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/src/agents/pi-embedded-runner/run/failover-observation.ts b/src/agents/pi-embedded-runner/run/failover-observation.ts
index 8e316a96d3d..c4c50b18e47 100644
--- a/src/agents/pi-embedded-runner/run/failover-observation.ts
+++ b/src/agents/pi-embedded-runner/run/failover-observation.ts
@@ -4,7 +4,7 @@ import { buildApiErrorObservationFields } from "../../pi-embedded-error-observat
 import type { FailoverReason } from "../../pi-embedded-helpers.js";
 import { log } from "../logger.js";
 
-export type FailoverDecisionObservation = {
+export type FailoverDecisionLoggerInput = {
   stage: "prompt" | "assistant";
   decision: "rotate_profile" | "fallback_model" | "surface_error";
   runId?: string;
@@ -20,11 +20,11 @@ export type FailoverDecisionObservation = {
   status?: number;
 };
 
-export type FailoverDecisionBase = Omit<FailoverDecisionObservation, "decision" | "status">;
+export type FailoverDecisionLoggerBase = Omit<FailoverDecisionLoggerInput, "decision" | "status">;
 
 export function normalizeFailoverDecisionObservationBase(
-  base: FailoverDecisionBase,
-): FailoverDecisionBase {
+  base: FailoverDecisionLoggerBase,
+): FailoverDecisionLoggerBase {
   return {
     ...base,
     failoverReason: base.failoverReason ?? (base.timedOut ? "timeout" : null),
@@ -33,10 +33,10 @@ export function normalizeFailoverDecisionObservationBase(
 }
 
 export function createFailoverDecisionLogger(
-  base: FailoverDecisionBase,
+  base: FailoverDecisionLoggerBase,
 ): (
-  decision: FailoverDecisionObservation["decision"],
-  extra?: Pick<FailoverDecisionObservation, "status">,
+  decision: FailoverDecisionLoggerInput["decision"],
+  extra?: Pick<FailoverDecisionLoggerInput, "status">,
 ) => void {
   const normalizedBase = normalizeFailoverDecisionObservationBase(base);
   const safeProfileId = normalizedBase.profileId