.NET: [Breaking] Rename AgentRunResponseEvent and AgentRunUpdateEvent classes (#3214)

SergeyMenshykh · web-flow · commit f56808b2792f · 2026-01-14T17:44:35.000Z
* rename AgentRunResponseEvent and AgentRunUpdateEvent classes

* rollback unnecessary changes
diff --git a/dotnet/samples/GettingStarted/Workflows/Agents/FoundryAgent/Program.cs b/dotnet/samples/GettingStarted/Workflows/Agents/FoundryAgent/Program.cs
@@ -45,7 +45,7 @@ private static async Task Main()
         await run.TrySendMessageAsync(new TurnToken(emitEvents: true));
         await foreach (WorkflowEvent evt in run.WatchStreamAsync())
         {
-            if (evt is AgentRunUpdateEvent executorComplete)
+            if (evt is AgentResponseUpdateEvent executorComplete)
             {
                 Console.WriteLine($"{executorComplete.ExecutorId}: {executorComplete.Data}");
             }
diff --git a/dotnet/samples/GettingStarted/Workflows/Declarative/ExecuteCode/Generated.cs b/dotnet/samples/GettingStarted/Workflows/Declarative/ExecuteCode/Generated.cs
@@ -76,7 +76,7 @@ await InvokeAgentAsync(
 
             if (autoSend)
             {
-                await context.AddEventAsync(new AgentRunResponseEvent(this.Id, agentResponse)).ConfigureAwait(false);
+                await context.AddEventAsync(new AgentResponseEvent(this.Id, agentResponse)).ConfigureAwait(false);
             }
 
             return default;
@@ -113,7 +113,7 @@ await InvokeAgentAsync(
 
             if (autoSend)
             {
-                await context.AddEventAsync(new AgentRunResponseEvent(this.Id, agentResponse)).ConfigureAwait(false);
+                await context.AddEventAsync(new AgentResponseEvent(this.Id, agentResponse)).ConfigureAwait(false);
             }
 
             await context.QueueStateUpdateAsync(key: "TeacherResponse", value: agentResponse.Messages, scopeName: "Local").ConfigureAwait(false);
@@ -176,7 +176,7 @@ GOLD STAR!
                     """
                 );
             AgentResponse response = new([new ChatMessage(ChatRole.Assistant, activityText)]);
-            await context.AddEventAsync(new AgentRunResponseEvent(this.Id, response)).ConfigureAwait(false);
+            await context.AddEventAsync(new AgentResponseEvent(this.Id, response)).ConfigureAwait(false);
 
             return default;
         }
@@ -197,7 +197,7 @@ await context.FormatTemplateAsync(
                     """
                 );
             AgentResponse response = new([new ChatMessage(ChatRole.Assistant, activityText)]);
-            await context.AddEventAsync(new AgentRunResponseEvent(this.Id, response)).ConfigureAwait(false);
+            await context.AddEventAsync(new AgentResponseEvent(this.Id, response)).ConfigureAwait(false);
 
             return default;
         }
diff --git a/dotnet/samples/GettingStarted/Workflows/_Foundational/03_AgentsInWorkflows/Program.cs b/dotnet/samples/GettingStarted/Workflows/_Foundational/03_AgentsInWorkflows/Program.cs
@@ -52,7 +52,7 @@ private static async Task Main()
         await run.TrySendMessageAsync(new TurnToken(emitEvents: true));
         await foreach (WorkflowEvent evt in run.WatchStreamAsync())
         {
-            if (evt is AgentRunUpdateEvent executorComplete)
+            if (evt is AgentResponseUpdateEvent executorComplete)
             {
                 Console.WriteLine($"{executorComplete.ExecutorId}: {executorComplete.Data}");
             }
diff --git a/dotnet/samples/GettingStarted/Workflows/_Foundational/04_AgentWorkflowPatterns/Program.cs b/dotnet/samples/GettingStarted/Workflows/_Foundational/04_AgentWorkflowPatterns/Program.cs
@@ -88,7 +88,7 @@ static async Task<List<ChatMessage>> RunWorkflowAsync(Workflow workflow, List<Ch
             await run.TrySendMessageAsync(new TurnToken(emitEvents: true));
             await foreach (WorkflowEvent evt in run.WatchStreamAsync())
             {
-                if (evt is AgentRunUpdateEvent e)
+                if (evt is AgentResponseUpdateEvent e)
                 {
                     if (e.ExecutorId != lastExecutorId)
                     {
diff --git a/dotnet/samples/GettingStarted/Workflows/_Foundational/07_MixedWorkflowAgentsAndExecutors/Program.cs b/dotnet/samples/GettingStarted/Workflows/_Foundational/07_MixedWorkflowAgentsAndExecutors/Program.cs
@@ -143,12 +143,12 @@ private static async Task ExecuteWorkflowAsync(Workflow workflow, string input)
                     // Don't print internal executor outputs, let them handle their own printing
                     break;
 
-                case AgentRunUpdateEvent:
+                case AgentResponseUpdateEvent:
                     // Show agent thinking in real-time (optional)
-                    if (ShowAgentThinking && !string.IsNullOrEmpty(((AgentRunUpdateEvent)evt).Update.Text))
+                    if (ShowAgentThinking && !string.IsNullOrEmpty(((AgentResponseUpdateEvent)evt).Update.Text))
                     {
                         Console.ForegroundColor = ConsoleColor.DarkYellow;
-                        Console.Write(((AgentRunUpdateEvent)evt).Update.Text);
+                        Console.Write(((AgentResponseUpdateEvent)evt).Update.Text);
                         Console.ResetColor();
                     }
                     break;
diff --git a/dotnet/samples/GettingStarted/Workflows/_Foundational/08_WriterCriticWorkflow/Program.cs b/dotnet/samples/GettingStarted/Workflows/_Foundational/08_WriterCriticWorkflow/Program.cs
@@ -96,7 +96,7 @@ private static async Task ExecuteWorkflowAsync(Workflow workflow, string input)
         {
             switch (evt)
             {
-                case AgentRunUpdateEvent agentUpdate:
+                case AgentResponseUpdateEvent agentUpdate:
                     // Stream agent output in real-time
                     if (!string.IsNullOrEmpty(agentUpdate.Update.Text))
                     {
diff --git a/dotnet/src/Microsoft.Agents.AI.Workflows.Declarative/CodeGen/InvokeAzureAgentTemplate.cs b/dotnet/src/Microsoft.Agents.AI.Workflows.Declarative/CodeGen/InvokeAzureAgentTemplate.cs
@@ -75,7 +75,7 @@ await InvokeAgentAsync(
 
         if (autoSend)
         {
-            await context.AddEventAsync(new AgentRunResponseEvent(this.Id, agentResponse)).ConfigureAwait(false);
+            await context.AddEventAsync(new AgentResponseEvent(this.Id, agentResponse)).ConfigureAwait(false);
         }
         ");
 
diff --git a/dotnet/src/Microsoft.Agents.AI.Workflows.Declarative/CodeGen/InvokeAzureAgentTemplate.tt b/dotnet/src/Microsoft.Agents.AI.Workflows.Declarative/CodeGen/InvokeAzureAgentTemplate.tt
@@ -32,7 +32,7 @@ internal sealed class <#= this.Name #>Executor(FormulaSession session, WorkflowA
 
         if (autoSend)
         {
-            await context.AddEventAsync(new AgentRunResponseEvent(this.Id, agentResponse)).ConfigureAwait(false);
+            await context.AddEventAsync(new AgentResponseEvent(this.Id, agentResponse)).ConfigureAwait(false);
         }
         <#
         AssignVariable(this.Messages, "agentResponse.Messages"); #>
diff --git a/dotnet/src/Microsoft.Agents.AI.Workflows.Declarative/CodeGen/SendActivityTemplate.cs b/dotnet/src/Microsoft.Agents.AI.Workflows.Declarative/CodeGen/SendActivityTemplate.cs
@@ -72,7 +72,7 @@ public override string TransformText()
     } 
      
             this.Write("\n            );\n        AgentResponse response = new([new ChatMessage(ChatRole" +
-                    ".Assistant, activityText)]);\n        await context.AddEventAsync(new AgentRunRes" +
+                    ".Assistant, activityText)]);\n        await context.AddEventAsync(new AgentRes" +
                     "ponseEvent(this.Id, response)).ConfigureAwait(false);");
 
 } 
diff --git a/dotnet/src/Microsoft.Agents.AI.Workflows.Declarative/CodeGen/SendActivityTemplate.tt b/dotnet/src/Microsoft.Agents.AI.Workflows.Declarative/CodeGen/SendActivityTemplate.tt
@@ -26,7 +26,7 @@ if (this.Model.Activity is MessageActivityTemplate messageActivity)
      #>
             );
         AgentResponse response = new([new ChatMessage(ChatRole.Assistant, activityText)]);
-        await context.AddEventAsync(new AgentRunResponseEvent(this.Id, response)).ConfigureAwait(false);<#
+        await context.AddEventAsync(new AgentResponseEvent(this.Id, response)).ConfigureAwait(false);<#
 } #>
 
         return default;
diff --git a/dotnet/src/Microsoft.Agents.AI.Workflows.Declarative/Extensions/AgentProviderExtensions.cs b/dotnet/src/Microsoft.Agents.AI.Workflows.Declarative/Extensions/AgentProviderExtensions.cs
@@ -36,15 +36,15 @@ public static async ValueTask<AgentResponse> InvokeAgentAsync(
 
             if (autoSend)
             {
-                await context.AddEventAsync(new AgentRunUpdateEvent(executorId, update), cancellationToken).ConfigureAwait(false);
+                await context.AddEventAsync(new AgentResponseUpdateEvent(executorId, update), cancellationToken).ConfigureAwait(false);
             }
         }
 
         AgentResponse response = updates.ToAgentResponse();
 
         if (autoSend)
         {
-            await context.AddEventAsync(new AgentRunResponseEvent(executorId, response), cancellationToken).ConfigureAwait(false);
+            await context.AddEventAsync(new AgentResponseEvent(executorId, response), cancellationToken).ConfigureAwait(false);
         }
 
         // If autoSend is enabled and this is not the workflow conversation, copy messages to the workflow conversation.
diff --git a/dotnet/src/Microsoft.Agents.AI.Workflows.Declarative/ObjectModel/AddConversationMessageExecutor.cs b/dotnet/src/Microsoft.Agents.AI.Workflows.Declarative/ObjectModel/AddConversationMessageExecutor.cs
@@ -30,7 +30,7 @@ internal sealed class AddConversationMessageExecutor(AddConversationMessage mode
 
         if (isWorkflowConversation)
         {
-            await context.AddEventAsync(new AgentRunResponseEvent(this.Id, new AgentResponse(newMessage)), cancellationToken).ConfigureAwait(false);
+            await context.AddEventAsync(new AgentResponseEvent(this.Id, new AgentResponse(newMessage)), cancellationToken).ConfigureAwait(false);
         }
 
         return default;
diff --git a/dotnet/src/Microsoft.Agents.AI.Workflows.Declarative/ObjectModel/CopyConversationMessagesExecutor.cs b/dotnet/src/Microsoft.Agents.AI.Workflows.Declarative/ObjectModel/CopyConversationMessagesExecutor.cs
@@ -33,7 +33,7 @@ internal sealed class CopyConversationMessagesExecutor(CopyConversationMessages
 
             if (isWorkflowConversation)
             {
-                await context.AddEventAsync(new AgentRunResponseEvent(this.Id, new AgentResponse([.. inputMessages])), cancellationToken).ConfigureAwait(false);
+                await context.AddEventAsync(new AgentResponseEvent(this.Id, new AgentResponse([.. inputMessages])), cancellationToken).ConfigureAwait(false);
             }
         }
 
diff --git a/dotnet/src/Microsoft.Agents.AI.Workflows/AgentResponseEvent.cs b/dotnet/src/Microsoft.Agents.AI.Workflows/AgentResponseEvent.cs
@@ -5,22 +5,22 @@
 namespace Microsoft.Agents.AI.Workflows;
 
 /// <summary>
-/// Represents an event triggered when an agent run produces an update.
+/// Represents an event triggered when an agent produces a response.
 /// </summary>
-public class AgentRunResponseEvent : ExecutorEvent
+public class AgentResponseEvent : ExecutorEvent
 {
     /// <summary>
-    /// Initializes a new instance of the <see cref="AgentRunUpdateEvent"/> class.
+    /// Initializes a new instance of the <see cref="AgentResponseEvent"/> class.
     /// </summary>
     /// <param name="executorId">The identifier of the executor that generated this event.</param>
-    /// <param name="response">The agent run response.</param>
-    public AgentRunResponseEvent(string executorId, AgentResponse response) : base(executorId, data: response)
+    /// <param name="response">The agent response.</param>
+    public AgentResponseEvent(string executorId, AgentResponse response) : base(executorId, data: response)
     {
         this.Response = Throw.IfNull(response);
     }
 
     /// <summary>
-    /// Gets the agent run response.
+    /// Gets the agent response.
     /// </summary>
     public AgentResponse Response { get; }
 }
diff --git a/dotnet/src/Microsoft.Agents.AI.Workflows/AgentResponseUpdateEvent.cs b/dotnet/src/Microsoft.Agents.AI.Workflows/AgentResponseUpdateEvent.cs
@@ -8,14 +8,14 @@ namespace Microsoft.Agents.AI.Workflows;
 /// <summary>
 /// Represents an event triggered when an agent run produces an update.
 /// </summary>
-public class AgentRunUpdateEvent : ExecutorEvent
+public class AgentResponseUpdateEvent : ExecutorEvent
 {
     /// <summary>
-    /// Initializes a new instance of the <see cref="AgentRunUpdateEvent"/> class.
+    /// Initializes a new instance of the <see cref="AgentResponseUpdateEvent"/> class.
     /// </summary>
     /// <param name="executorId">The identifier of the executor that generated this event.</param>
     /// <param name="update">The agent run response update.</param>
-    public AgentRunUpdateEvent(string executorId, AgentResponseUpdate update) : base(executorId, data: update)
+    public AgentResponseUpdateEvent(string executorId, AgentResponseUpdate update) : base(executorId, data: update)
     {
         this.Update = Throw.IfNull(update);
     }
diff --git a/dotnet/src/Microsoft.Agents.AI.Workflows/Specialized/AIAgentHostExecutor.cs b/dotnet/src/Microsoft.Agents.AI.Workflows/Specialized/AIAgentHostExecutor.cs
@@ -63,7 +63,7 @@ await this.EnsureThreadAsync(context, cancellationToken).ConfigureAwait(false),
 
             await foreach (AgentResponseUpdate update in agentStream.ConfigureAwait(false))
             {
-                await context.AddEventAsync(new AgentRunUpdateEvent(this.Id, update), cancellationToken).ConfigureAwait(false);
+                await context.AddEventAsync(new AgentResponseUpdateEvent(this.Id, update), cancellationToken).ConfigureAwait(false);
 
                 // TODO: FunctionCall request handling, and user info request handling.
                 // In some sense: We should just let it be handled as a ChatMessage, though we should consider
diff --git a/dotnet/src/Microsoft.Agents.AI.Workflows/Specialized/AgentRunStreamingExecutor.cs b/dotnet/src/Microsoft.Agents.AI.Workflows/Specialized/AgentRunStreamingExecutor.cs
@@ -28,7 +28,7 @@ protected override async ValueTask TakeTurnAsync(List<ChatMessage> messages, IWo
             updates.Add(update);
             if (emitEvents is true)
             {
-                await context.AddEventAsync(new AgentRunUpdateEvent(this.Id, update), cancellationToken).ConfigureAwait(false);
+                await context.AddEventAsync(new AgentResponseUpdateEvent(this.Id, update), cancellationToken).ConfigureAwait(false);
             }
         }
 
diff --git a/dotnet/src/Microsoft.Agents.AI.Workflows/Specialized/HandoffAgentExecutor.cs b/dotnet/src/Microsoft.Agents.AI.Workflows/Specialized/HandoffAgentExecutor.cs
@@ -109,7 +109,7 @@ async Task AddUpdateAsync(AgentResponseUpdate update, CancellationToken cancella
                 updates.Add(update);
                 if (handoffState.TurnToken.EmitEvents is true)
                 {
-                    await context.AddEventAsync(new AgentRunUpdateEvent(this.Id, update), cancellationToken).ConfigureAwait(false);
+                    await context.AddEventAsync(new AgentResponseUpdateEvent(this.Id, update), cancellationToken).ConfigureAwait(false);
                 }
             }
         });
diff --git a/dotnet/src/Microsoft.Agents.AI.Workflows/WorkflowThread.cs b/dotnet/src/Microsoft.Agents.AI.Workflows/WorkflowThread.cs
@@ -151,7 +151,7 @@ IAsyncEnumerable<AgentResponseUpdate> InvokeStageAsync(
             {
                 switch (evt)
                 {
-                    case AgentRunUpdateEvent agentUpdate:
+                    case AgentResponseUpdateEvent agentUpdate:
                         yield return agentUpdate.Update;
                         break;
 
diff --git a/dotnet/src/Shared/Workflows/Execution/WorkflowRunner.cs b/dotnet/src/Shared/Workflows/Execution/WorkflowRunner.cs
@@ -177,7 +177,7 @@ public async Task ExecuteAsync(Func<Workflow> workflowProvider, string input)
                     Console.ResetColor();
                     break;
 
-                case AgentRunUpdateEvent streamEvent:
+                case AgentResponseUpdateEvent streamEvent:
                     if (!string.Equals(messageId, streamEvent.Update.MessageId, StringComparison.Ordinal))
                     {
                         hasStreamed = false;
@@ -230,7 +230,7 @@ public async Task ExecuteAsync(Func<Workflow> workflowProvider, string input)
                     }
                     break;
 
-                case AgentRunResponseEvent messageEvent:
+                case AgentResponseEvent messageEvent:
                     try
                     {
                         if (hasStreamed)
diff --git a/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.IntegrationTests/Framework/WorkflowEvents.cs b/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.IntegrationTests/Framework/WorkflowEvents.cs
@@ -18,7 +18,7 @@ public WorkflowEvents(IReadOnlyList<WorkflowEvent> workflowEvents)
         this.ExecutorInvokeEvents = workflowEvents.OfType<ExecutorInvokedEvent>().ToList();
         this.ExecutorCompleteEvents = workflowEvents.OfType<ExecutorCompletedEvent>().ToList();
         this.InputEvents = workflowEvents.OfType<RequestInfoEvent>().ToList();
-        this.AgentResponseEvents = workflowEvents.OfType<AgentRunResponseEvent>().ToList();
+        this.AgentResponseEvents = workflowEvents.OfType<AgentResponseEvent>().ToList();
     }
 
     public IReadOnlyList<WorkflowEvent> Events { get; }
@@ -29,5 +29,5 @@ public WorkflowEvents(IReadOnlyList<WorkflowEvent> workflowEvents)
     public IReadOnlyList<ExecutorInvokedEvent> ExecutorInvokeEvents { get; }
     public IReadOnlyList<ExecutorCompletedEvent> ExecutorCompleteEvents { get; }
     public IReadOnlyList<RequestInfoEvent> InputEvents { get; }
-    public IReadOnlyList<AgentRunResponseEvent> AgentResponseEvents { get; }
+    public IReadOnlyList<AgentResponseEvent> AgentResponseEvents { get; }
 }
diff --git a/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.IntegrationTests/Framework/WorkflowHarness.cs b/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.IntegrationTests/Framework/WorkflowHarness.cs
@@ -142,7 +142,7 @@ private static async IAsyncEnumerable<WorkflowEvent> MonitorAndDisposeWorkflowRu
                     Console.WriteLine($"ACTION: {actionInvokeEvent.ActionId} [{actionInvokeEvent.ActionType}]");
                     break;
 
-                case AgentRunResponseEvent responseEvent:
+                case AgentResponseEvent responseEvent:
                     if (!string.IsNullOrEmpty(responseEvent.Response.Text))
                     {
                         Console.WriteLine($"AGENT: {responseEvent.Response.AgentId}: {responseEvent.Response.Text}");
diff --git a/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.IntegrationTests/Framework/WorkflowTest.cs b/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.IntegrationTests/Framework/WorkflowTest.cs
@@ -124,7 +124,7 @@ public static void EventCounts(int actualCount, Testcase testcase, bool isComple
             }
         }
 
-        public static void Responses(IReadOnlyList<AgentRunResponseEvent> responseEvents, Testcase testcase)
+        public static void Responses(IReadOnlyList<AgentResponseEvent> responseEvents, Testcase testcase)
         {
             Assert.True(responseEvents.Count >= testcase.Validation.MinResponseCount, $"Response count less than expected: {testcase.Validation.MinResponseCount} (Actual: {responseEvents.Count})");
             if (testcase.Validation.MaxResponseCount != -1)
diff --git a/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.IntegrationTests/MediaInputTest.cs b/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.IntegrationTests/MediaInputTest.cs
@@ -84,7 +84,7 @@ private async Task ValidateFileAsync(AIContent fileContent)
         WorkflowEvents workflowEvents = await harness.RunWorkflowAsync(inputMessage).ConfigureAwait(false);
         ConversationUpdateEvent conversationEvent = Assert.Single(workflowEvents.ConversationEvents);
         this.Output.WriteLine("CONVERSATION: " + conversationEvent.ConversationId);
-        AgentRunResponseEvent agentResponseEvent = Assert.Single(workflowEvents.AgentResponseEvents);
+        AgentResponseEvent agentResponseEvent = Assert.Single(workflowEvents.AgentResponseEvents);
         this.Output.WriteLine("RESPONSE: " + agentResponseEvent.Response.Text);
         Assert.NotEmpty(agentResponseEvent.Response.Text);
     }
diff --git a/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.UnitTests/DeclarativeWorkflowTest.cs b/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.UnitTests/DeclarativeWorkflowTest.cs
@@ -352,7 +352,7 @@ private async Task RunWorkflowAsync<TInput>(string workflowPath, TInput workflow
                     this.Output.WriteLine($"ACTIVITY: {activityEvent.Message}");
                     break;
 
-                case AgentRunResponseEvent messageEvent:
+                case AgentResponseEvent messageEvent:
                     this.Output.WriteLine($"MESSAGE: {messageEvent.Response.Messages[0].Text.Trim()}");
                     break;
 
diff --git a/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.UnitTests/Workflows/CancelWorkflow.cs b/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.UnitTests/Workflows/CancelWorkflow.cs
@@ -61,7 +61,7 @@ NEVER 1!
                     """
                 );
             AgentResponse response = new([new ChatMessage(ChatRole.Assistant, activityText)]);
-            await context.AddEventAsync(new AgentRunResponseEvent(this.Id, response)).ConfigureAwait(false);
+            await context.AddEventAsync(new AgentResponseEvent(this.Id, response)).ConfigureAwait(false);
     
             return default;
         }
diff --git a/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.UnitTests/Workflows/Condition.cs b/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.UnitTests/Workflows/Condition.cs
diff --git a/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.UnitTests/Workflows/ConditionElse.cs b/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.UnitTests/Workflows/ConditionElse.cs
diff --git a/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.UnitTests/Workflows/EndConversation.cs b/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.UnitTests/Workflows/EndConversation.cs
diff --git a/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.UnitTests/Workflows/EndWorkflow.cs b/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.UnitTests/Workflows/EndWorkflow.cs
diff --git a/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.UnitTests/Workflows/Goto.cs b/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.UnitTests/Workflows/Goto.cs
diff --git a/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.UnitTests/Workflows/InvokeAgent.cs b/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.UnitTests/Workflows/InvokeAgent.cs
diff --git a/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.UnitTests/Workflows/LoopBreak.cs b/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.UnitTests/Workflows/LoopBreak.cs
diff --git a/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.UnitTests/Workflows/LoopContinue.cs b/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.UnitTests/Workflows/LoopContinue.cs
diff --git a/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.UnitTests/Workflows/LoopEach.cs b/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.UnitTests/Workflows/LoopEach.cs
diff --git a/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.UnitTests/Workflows/SendActivity.cs b/dotnet/tests/Microsoft.Agents.AI.Workflows.Declarative.UnitTests/Workflows/SendActivity.cs
diff --git a/dotnet/tests/Microsoft.Agents.AI.Workflows.UnitTests/AgentWorkflowBuilderTests.cs b/dotnet/tests/Microsoft.Agents.AI.Workflows.UnitTests/AgentWorkflowBuilderTests.cs
diff --git a/dotnet/tests/Microsoft.Agents.AI.Workflows.UnitTests/InProcessExecutionTests.cs b/dotnet/tests/Microsoft.Agents.AI.Workflows.UnitTests/InProcessExecutionTests.cs
diff --git a/dotnet/tests/Microsoft.Agents.AI.Workflows.UnitTests/Sample/06_GroupChat_Workflow.cs b/dotnet/tests/Microsoft.Agents.AI.Workflows.UnitTests/Sample/06_GroupChat_Workflow.cs

Original file line number	Diff line number	Diff line change
`@@ -45,7 +45,7 @@ private static async Task Main()`
`45`	`45`	`await run.TrySendMessageAsync(new TurnToken(emitEvents: true));`
`46`	`46`	`await foreach (WorkflowEvent evt in run.WatchStreamAsync())`
`47`	`47`	`{`
`48`		`- if (evt is AgentRunUpdateEvent executorComplete)`
	`48`	`+ if (evt is AgentResponseUpdateEvent executorComplete)`
`49`	`49`	`{`
`50`	`50`	`Console.WriteLine($"{executorComplete.ExecutorId}: {executorComplete.Data}");`
`51`	`51`	`}`
Original file line number	Diff line number	Diff line change
`@@ -76,7 +76,7 @@ await InvokeAgentAsync(`
`76`	`76`
`77`	`77`	`if (autoSend)`
`78`	`78`	`{`
`79`		`- await context.AddEventAsync(new AgentRunResponseEvent(this.Id, agentResponse)).ConfigureAwait(false);`
	`79`	`+ await context.AddEventAsync(new AgentResponseEvent(this.Id, agentResponse)).ConfigureAwait(false);`
`80`	`80`	`}`
`81`	`81`
`82`	`82`	`return default;`
`@@ -113,7 +113,7 @@ await InvokeAgentAsync(`
`113`	`113`
`114`	`114`	`if (autoSend)`
`115`	`115`	`{`
`116`		`- await context.AddEventAsync(new AgentRunResponseEvent(this.Id, agentResponse)).ConfigureAwait(false);`
	`116`	`+ await context.AddEventAsync(new AgentResponseEvent(this.Id, agentResponse)).ConfigureAwait(false);`
`117`	`117`	`}`
`118`	`118`
`119`	`119`	`await context.QueueStateUpdateAsync(key: "TeacherResponse", value: agentResponse.Messages, scopeName: "Local").ConfigureAwait(false);`
`@@ -176,7 +176,7 @@ GOLD STAR!`
`176`	`176`	`"""`
`177`	`177`	`);`
`178`	`178`	`AgentResponse response = new([new ChatMessage(ChatRole.Assistant, activityText)]);`
`179`		`- await context.AddEventAsync(new AgentRunResponseEvent(this.Id, response)).ConfigureAwait(false);`
	`179`	`+ await context.AddEventAsync(new AgentResponseEvent(this.Id, response)).ConfigureAwait(false);`
`180`	`180`
`181`	`181`	`return default;`
`182`	`182`	`}`
`@@ -197,7 +197,7 @@ await context.FormatTemplateAsync(`
`197`	`197`	`"""`
`198`	`198`	`);`
`199`	`199`	`AgentResponse response = new([new ChatMessage(ChatRole.Assistant, activityText)]);`
`200`		`- await context.AddEventAsync(new AgentRunResponseEvent(this.Id, response)).ConfigureAwait(false);`
	`200`	`+ await context.AddEventAsync(new AgentResponseEvent(this.Id, response)).ConfigureAwait(false);`
`201`	`201`
`202`	`202`	`return default;`
`203`	`203`	`}`
Original file line number	Diff line number	Diff line change
`@@ -52,7 +52,7 @@ private static async Task Main()`
`52`	`52`	`await run.TrySendMessageAsync(new TurnToken(emitEvents: true));`
`53`	`53`	`await foreach (WorkflowEvent evt in run.WatchStreamAsync())`
`54`	`54`	`{`
`55`		`- if (evt is AgentRunUpdateEvent executorComplete)`
	`55`	`+ if (evt is AgentResponseUpdateEvent executorComplete)`
`56`	`56`	`{`
`57`	`57`	`Console.WriteLine($"{executorComplete.ExecutorId}: {executorComplete.Data}");`
`58`	`58`	`}`
Original file line number	Diff line number	Diff line change
`@@ -88,7 +88,7 @@ static async Task<List<ChatMessage>> RunWorkflowAsync(Workflow workflow, List<Ch`
`88`	`88`	`await run.TrySendMessageAsync(new TurnToken(emitEvents: true));`
`89`	`89`	`await foreach (WorkflowEvent evt in run.WatchStreamAsync())`
`90`	`90`	`{`
`91`		`- if (evt is AgentRunUpdateEvent e)`
	`91`	`+ if (evt is AgentResponseUpdateEvent e)`
`92`	`92`	`{`
`93`	`93`	`if (e.ExecutorId != lastExecutorId)`
`94`	`94`	`{`
Original file line number	Diff line number	Diff line change
`@@ -96,7 +96,7 @@ private static async Task ExecuteWorkflowAsync(Workflow workflow, string input)`
`96`	`96`	`{`
`97`	`97`	`switch (evt)`
`98`	`98`	`{`
`99`		`- case AgentRunUpdateEvent agentUpdate:`
	`99`	`+ case AgentResponseUpdateEvent agentUpdate:`
`100`	`100`	`// Stream agent output in real-time`
`101`	`101`	`if (!string.IsNullOrEmpty(agentUpdate.Update.Text))`
`102`	`102`	`{`
Original file line number	Diff line number	Diff line change
`@@ -75,7 +75,7 @@ await InvokeAgentAsync(`
`75`	`75`
`76`	`76`	`if (autoSend)`
`77`	`77`	`{`
`78`		`- await context.AddEventAsync(new AgentRunResponseEvent(this.Id, agentResponse)).ConfigureAwait(false);`
	`78`	`+ await context.AddEventAsync(new AgentResponseEvent(this.Id, agentResponse)).ConfigureAwait(false);`
`79`	`79`	`}`
`80`	`80`	`");`
`81`	`81`
Original file line number	Diff line number	Diff line change
`@@ -32,7 +32,7 @@ internal sealed class <#= this.Name #>Executor(FormulaSession session, WorkflowA`
`32`	`32`
`33`	`33`	`if (autoSend)`
`34`	`34`	`{`
`35`		`- await context.AddEventAsync(new AgentRunResponseEvent(this.Id, agentResponse)).ConfigureAwait(false);`
	`35`	`+ await context.AddEventAsync(new AgentResponseEvent(this.Id, agentResponse)).ConfigureAwait(false);`
`36`	`36`	`}`
`37`	`37`	`<#`
`38`	`38`	`AssignVariable(this.Messages, "agentResponse.Messages"); #>`
Original file line number	Diff line number	Diff line change
`@@ -72,7 +72,7 @@ public override string TransformText()`
`72`	`72`	`}`
`73`	`73`
`74`	`74`	`this.Write("\n );\n AgentResponse response = new([new ChatMessage(ChatRole" +`
`75`		`- ".Assistant, activityText)]);\n await context.AddEventAsync(new AgentRunRes" +`
	`75`	`+ ".Assistant, activityText)]);\n await context.AddEventAsync(new AgentRes" +`
`76`	`76`	`"ponseEvent(this.Id, response)).ConfigureAwait(false);");`
`77`	`77`
`78`	`78`	`}`