fix(agent-core-v2): suppress automatic MCP retry status repeats (#4492)

Author: sailist

packages/agent-core-v2/src/mcpCore/connection-manager.ts

@@ -484,6 +484,7 @@ export class McpConnectionManager implements McpConnectionView {
   private transition(entry: InternalEntry, event: McpEntryEvent): void {
     const plan = this.planTransition(entry, event);
     if (plan === undefined) return;
+    const automaticRetry = entry.state === 'connecting' && entry.failureStreak > 0;
     const before = toPublicEntry(entry);
     const fromFamily = entry.state === 'connected' || entry.state === 'probing';
     const toFamily = plan.target === 'connected' || plan.target === 'probing';
@@ -570,7 +571,8 @@ export class McpConnectionManager implements McpConnectionView {
         break;
     }
     const after = toPublicEntry(entry);
-    if (plan.forceEmit === true || !publicEntriesEqual(before, after)) {
+    const suppressRetryStatus = event.type === 'retryDue' || (automaticRetry && plan.target === 'retryWaiting');
+    if (!suppressRetryStatus && (plan.forceEmit === true || !publicEntriesEqual(before, after))) {
       this.emit(entry);
     }
     this.scheduleReconcile();

packages/agent-core-v2/test/mcpCore/connection-manager.test.ts

@@ -943,9 +943,6 @@ describe('McpConnectionManager', () => {
         'pending',
         'failed',
         'failed',
-        'pending',
-        'failed',
-        'pending',
         'connected',
       ]);
     } finally {
@@ -1040,9 +1037,6 @@ describe('McpConnectionManager', () => {
       expect(seen.filter((s) => s.name === 'remote').map((s) => s.status)).toEqual([
         'pending',
         'failed',
-        'pending',
-        'failed',
-        'pending',
         'connected',
       ]);
     } finally {
@@ -1409,8 +1403,7 @@ describe('McpConnectionManager', () => {
       expect(cm.resolved('remote')).toBeDefined();
 
       const remoteStatuses = seen.filter((s) => s.name === 'remote').map((s) => s.status);
-      expect(remoteStatuses.slice(0, 3)).toEqual(['pending', 'connected', 'failed']);
-      expect(remoteStatuses.slice(-2)).toEqual(['pending', 'connected']);
+      expect(remoteStatuses).toEqual(['pending', 'connected', 'failed', 'connected']);
     } finally {
       await cm.shutdown();
       await closeServer(httpServer);