.Net: Removing groupchat from samples that have a single agent and aren't demonstrating a groupchat concept (microsoft#11261)

westey-m · markwallace-microsoft · glorious-beard · commit 2f1974dbefbc · 2025-04-06T16:24:25.000-07:00
### Motivation and Context Addressing Feedback from bugbash ### Description Removing groupchat from samples that have a single agent and aren't demonstrating a groupchat concept ### Contribution Checklist  - [ ] The code builds clean without any errors or warnings - [ ] The PR follows the [SK Contribution Guidelines](https://github.com/microsoft/semantic-kernel/blob/main/CONTRIBUTING.md) and the [pre-submission formatting script](https://github.com/microsoft/semantic-kernel/blob/main/CONTRIBUTING.md#development-scripts) raises no violations - [ ] All unit tests pass, and I have added new tests where possible - [ ] I didn't break anyone 😄 Co-authored-by: Mark Wallace <127216156+markwallace-microsoft@users.noreply.github.com>
diff --git a/dotnet/samples/Concepts/Agents/AzureAIAgent_FileManipulation.cs b/dotnet/samples/Concepts/Agents/AzureAIAgent_FileManipulation.cs
@@ -1,7 +1,6 @@
 ﻿// Copyright (c) Microsoft. All rights reserved.
 using Azure.AI.Projects;
 using Microsoft.SemanticKernel;
-using Microsoft.SemanticKernel.Agents;
 using Microsoft.SemanticKernel.Agents.AzureAI;
 using Microsoft.SemanticKernel.ChatCompletion;
 using Resources;
@@ -33,9 +32,7 @@ public async Task AnalyzeCSVFileUsingAzureAIAgentAsync()
                     }
                 });
         AzureAIAgent agent = new(definition, this.AgentsClient);
-
-        // Create a chat for agent interaction.
-        AgentGroupChat chat = new();
+        AzureAIAgentThread thread = new(this.AgentsClient);
 
         // Respond to user input
         try
@@ -46,19 +43,18 @@ public async Task AnalyzeCSVFileUsingAzureAIAgentAsync()
         }
         finally
         {
+            await thread.DeleteAsync();
             await this.AgentsClient.DeleteAgentAsync(agent.Id);
             await this.AgentsClient.DeleteFileAsync(fileInfo.Id);
-            await chat.ResetAsync();
         }
 
         // Local function to invoke agent and display the conversation messages.
         async Task InvokeAgentAsync(string input)
         {
             ChatMessageContent message = new(AuthorRole.User, input);
-            chat.AddChatMessage(new(AuthorRole.User, input));
             this.WriteAgentChatMessage(message);
 
-            await foreach (ChatMessageContent response in chat.InvokeAsync(agent))
+            await foreach (ChatMessageContent response in agent.InvokeAsync(message, thread))
             {
                 this.WriteAgentChatMessage(response);
                 await this.DownloadContentAsync(response);
diff --git a/dotnet/samples/Concepts/Agents/ChatCompletion_FunctionTermination.cs b/dotnet/samples/Concepts/Agents/ChatCompletion_FunctionTermination.cs
@@ -53,47 +53,6 @@ async Task InvokeAgentAsync(string input)
         }
     }
 
-    [Fact]
-    public async Task UseAutoFunctionInvocationFilterWithAgentChatAsync()
-    {
-        // Define the agent
-        ChatCompletionAgent agent =
-            new()
-            {
-                Instructions = "Answer questions about the menu.",
-                Kernel = CreateKernelWithFilter(),
-                Arguments = new KernelArguments(new PromptExecutionSettings() { FunctionChoiceBehavior = FunctionChoiceBehavior.Auto() }),
-            };
-
-        KernelPlugin plugin = KernelPluginFactory.CreateFromType<MenuPlugin>();
-        agent.Kernel.Plugins.Add(plugin);
-
-        // Create a chat for agent interaction.
-        AgentGroupChat chat = new();
-
-        // Respond to user input, invoking functions where appropriate.
-        await InvokeAgentAsync("Hello");
-        await InvokeAgentAsync("What is the special soup?");
-        await InvokeAgentAsync("What is the special drink?");
-        await InvokeAgentAsync("Thank you");
-
-        // Display the entire chat history.
-        WriteChatHistory(await chat.GetChatMessagesAsync().ToArrayAsync());
-
-        // Local function to invoke agent and display the conversation messages.
-        async Task InvokeAgentAsync(string input)
-        {
-            ChatMessageContent message = new(AuthorRole.User, input);
-            chat.AddChatMessage(message);
-            this.WriteAgentChatMessage(message);
-
-            await foreach (ChatMessageContent response in chat.InvokeAsync(agent))
-            {
-                this.WriteAgentChatMessage(response);
-            }
-        }
-    }
-
     [Fact]
     public async Task UseAutoFunctionInvocationFilterWithStreamingAgentInvocationAsync()
     {
@@ -156,59 +115,6 @@ async Task InvokeAgentAsync(string input)
         }
     }
 
-    [Fact]
-    public async Task UseAutoFunctionInvocationFilterWithStreamingAgentChatAsync()
-    {
-        // Define the agent
-        ChatCompletionAgent agent =
-            new()
-            {
-                Instructions = "Answer questions about the menu.",
-                Kernel = CreateKernelWithFilter(),
-                Arguments = new KernelArguments(new PromptExecutionSettings() { FunctionChoiceBehavior = FunctionChoiceBehavior.Auto() }),
-            };
-
-        KernelPlugin plugin = KernelPluginFactory.CreateFromType<MenuPlugin>();
-        agent.Kernel.Plugins.Add(plugin);
-
-        // Create a chat for agent interaction.
-        AgentGroupChat chat = new();
-
-        // Respond to user input, invoking functions where appropriate.
-        await InvokeAgentAsync("Hello");
-        await InvokeAgentAsync("What is the special soup?");
-        await InvokeAgentAsync("What is the special drink?");
-        await InvokeAgentAsync("Thank you");
-
-        // Display the entire chat history.
-        WriteChatHistory(await chat.GetChatMessagesAsync().ToArrayAsync());
-
-        // Local function to invoke agent and display the conversation messages.
-        async Task InvokeAgentAsync(string input)
-        {
-            ChatMessageContent message = new(AuthorRole.User, input);
-            chat.AddChatMessage(message);
-            this.WriteAgentChatMessage(message);
-
-            bool isFirst = false;
-            await foreach (StreamingChatMessageContent response in chat.InvokeStreamingAsync(agent))
-            {
-                if (string.IsNullOrEmpty(response.Content))
-                {
-                    continue;
-                }
-
-                if (!isFirst)
-                {
-                    Console.WriteLine($"\n# {response.Role} - {response.AuthorName ?? "*"}:");
-                    isFirst = true;
-                }
-
-                Console.WriteLine($"\t > streamed: '{response.Content}'");
-            }
-        }
-    }
-
     private void WriteChatHistory(IEnumerable<ChatMessageContent> chat)
     {
         Console.WriteLine("================================");
diff --git a/dotnet/samples/Concepts/Agents/ChatCompletion_HistoryReducer.cs b/dotnet/samples/Concepts/Agents/ChatCompletion_HistoryReducer.cs
@@ -41,32 +41,6 @@ public async Task SummarizedAgentReductionAsync()
         await InvokeAgentAsync(agent, 50);
     }
 
-    /// <summary>
-    /// Demonstrate the use of <see cref="ChatHistoryTruncationReducer"/> when using
-    /// <see cref="AgentGroupChat"/> to invoke a <see cref="ChatCompletionAgent"/>.
-    /// </summary>
-    [Fact]
-    public async Task TruncatedChatReductionAsync()
-    {
-        // Define the agent
-        ChatCompletionAgent agent = CreateTruncatingAgent(10, 10);
-
-        await InvokeChatAsync(agent, 50);
-    }
-
-    /// <summary>
-    /// Demonstrate the use of <see cref="ChatHistorySummarizationReducer"/> when using
-    /// <see cref="AgentGroupChat"/> to invoke a <see cref="ChatCompletionAgent"/>.
-    /// </summary>
-    [Fact]
-    public async Task SummarizedChatReductionAsync()
-    {
-        // Define the agent
-        ChatCompletionAgent agent = CreateSummarizingAgent(10, 10);
-
-        await InvokeChatAsync(agent, 50);
-    }
-
     // Proceed with dialog by directly invoking the agent and explicitly managing the history.
     private async Task InvokeAgentAsync(ChatCompletionAgent agent, int messageCount)
     {
@@ -105,48 +79,6 @@ private async Task InvokeAgentAsync(ChatCompletionAgent agent, int messageCount)
         }
     }
 
-    // Proceed with dialog with AgentGroupChat.
-    private async Task InvokeChatAsync(ChatCompletionAgent agent, int messageCount)
-    {
-        AgentGroupChat chat = new();
-
-        int lastHistoryCount = 0;
-
-        int index = 1;
-        while (index <= messageCount)
-        {
-            // Provide user input
-            chat.AddChatMessage(new ChatMessageContent(AuthorRole.User, $"{index}"));
-            Console.WriteLine($"# {AuthorRole.User}: '{index}'");
-
-            // Invoke and display assistant response
-            await foreach (ChatMessageContent message in chat.InvokeAsync(agent))
-            {
-                Console.WriteLine($"# {message.Role} - {message.AuthorName ?? "*"}: '{message.Content}'");
-            }
-
-            index += 2;
-
-            // Display the message count of the chat-history for visibility into reduction
-            // Note: Messages provided in descending order (newest first)
-            ChatMessageContent[] history = await chat.GetChatMessagesAsync(agent).ToArrayAsync();
-            Console.WriteLine($"@ Message Count: {history.Length}\n");
-
-            // Display summary messages (if present) if reduction has occurred
-            if (history.Length < lastHistoryCount)
-            {
-                int summaryIndex = history.Length - 1;
-                while (history[summaryIndex].Metadata?.ContainsKey(ChatHistorySummarizationReducer.SummaryMetadataKey) ?? false)
-                {
-                    Console.WriteLine($"\tSummary: {history[summaryIndex].Content}");
-                    --summaryIndex;
-                }
-            }
-
-            lastHistoryCount = history.Length;
-        }
-    }
-
     private ChatCompletionAgent CreateSummarizingAgent(int reducerMessageCount, int reducerThresholdCount)
     {
         Kernel kernel = this.CreateKernelWithChatCompletion();
diff --git a/dotnet/samples/Concepts/Agents/OpenAIAssistant_ChartMaker.cs b/dotnet/samples/Concepts/Agents/OpenAIAssistant_ChartMaker.cs
@@ -27,9 +27,7 @@ await this.AssistantClient.CreateAssistantAsync(
 
         // Create the agent
         OpenAIAssistantAgent agent = new(assistant, this.AssistantClient);
-
-        // Create a chat for agent interaction.
-        AgentGroupChat chat = new();
+        AgentThread? agentThread = null;
 
         // Respond to user input
         try
@@ -50,20 +48,26 @@ Sum      426  1622     856 2904
         }
         finally
         {
+            if (agentThread is not null)
+            {
+                await agentThread.DeleteAsync();
+            }
+
             await this.AssistantClient.DeleteAssistantAsync(agent.Id);
         }
 
         // Local function to invoke agent and display the conversation messages.
         async Task InvokeAgentAsync(string input)
         {
             ChatMessageContent message = new(AuthorRole.User, input);
-            chat.AddChatMessage(message);
             this.WriteAgentChatMessage(message);
 
-            await foreach (ChatMessageContent response in chat.InvokeAsync(agent))
+            await foreach (AgentResponseItem<ChatMessageContent> response in agent.InvokeAsync(message))
             {
                 this.WriteAgentChatMessage(response);
                 await this.DownloadResponseImageAsync(response);
+
+                agentThread = response.Thread;
             }
         }
     }
diff --git a/dotnet/samples/Concepts/Agents/OpenAIAssistant_FileManipulation.cs b/dotnet/samples/Concepts/Agents/OpenAIAssistant_FileManipulation.cs
@@ -29,9 +29,7 @@ await this.AssistantClient.CreateAssistantAsync(
 
         // Create the agent
         OpenAIAssistantAgent agent = new(assistant, this.AssistantClient);
-
-        // Create a chat for agent interaction.
-        AgentGroupChat chat = new();
+        AgentThread? agentThread = null;
 
         // Respond to user input
         try
@@ -42,6 +40,11 @@ await this.AssistantClient.CreateAssistantAsync(
         }
         finally
         {
+            if (agentThread is not null)
+            {
+                await agentThread.DeleteAsync();
+            }
+
             await this.AssistantClient.DeleteAssistantAsync(agent.Id);
             await this.Client.DeleteFileAsync(fileId);
         }
@@ -50,13 +53,14 @@ await this.AssistantClient.CreateAssistantAsync(
         async Task InvokeAgentAsync(string input)
         {
             ChatMessageContent message = new(AuthorRole.User, input);
-            chat.AddChatMessage(new(AuthorRole.User, input));
             this.WriteAgentChatMessage(message);
 
-            await foreach (ChatMessageContent response in chat.InvokeAsync(agent))
+            await foreach (AgentResponseItem<ChatMessageContent> response in agent.InvokeAsync(message))
             {
                 this.WriteAgentChatMessage(response);
                 await this.DownloadResponseContentAsync(response);
+
+                agentThread = response.Thread;
             }
         }
     }
diff --git a/dotnet/samples/Concepts/Agents/OpenAIAssistant_FunctionFilters.cs b/dotnet/samples/Concepts/Agents/OpenAIAssistant_FunctionFilters.cs
@@ -62,46 +62,42 @@ public async Task UseAutoFunctionInvocationFilterWithStreamingAgentInvocationAsy
 
     private async Task InvokeAssistantAsync(OpenAIAssistantAgent agent)
     {
-        // Create a thread for the agent conversation.
-        AgentGroupChat chat = new();
+        OpenAIAssistantAgentThread agentThread = new(this.AssistantClient);
 
         try
         {
             // Respond to user input, invoking functions where appropriate.
             ChatMessageContent message = new(AuthorRole.User, "What is the special soup?");
-            chat.AddChatMessage(message);
-            await chat.InvokeAsync(agent).ToArrayAsync();
+            await agent.InvokeAsync(message, agentThread).ToArrayAsync();
 
             // Display the entire chat history.
-            ChatMessageContent[] history = await chat.GetChatMessagesAsync().Reverse().ToArrayAsync();
+            ChatMessageContent[] history = await agentThread.GetMessagesAsync(MessageCollectionOrder.Ascending).ToArrayAsync();
             this.WriteChatHistory(history);
         }
         finally
         {
-            await chat.ResetAsync();
+            await agentThread.DeleteAsync();
             await this.AssistantClient.DeleteAssistantAsync(agent.Id);
         }
     }
 
     private async Task InvokeAssistantStreamingAsync(OpenAIAssistantAgent agent)
     {
-        // Create a thread for the agent conversation.
-        AgentGroupChat chat = new();
+        OpenAIAssistantAgentThread agentThread = new(this.AssistantClient);
 
         try
         {
             // Respond to user input, invoking functions where appropriate.
             ChatMessageContent message = new(AuthorRole.User, "What is the special soup?");
-            chat.AddChatMessage(message);
-            await chat.InvokeStreamingAsync(agent).ToArrayAsync();
+            await agent.InvokeStreamingAsync(message, agentThread).ToArrayAsync();
 
             // Display the entire chat history.
-            ChatMessageContent[] history = await chat.GetChatMessagesAsync().Reverse().ToArrayAsync();
+            ChatMessageContent[] history = await agentThread.GetMessagesAsync(MessageCollectionOrder.Ascending).ToArrayAsync();
             this.WriteChatHistory(history);
         }
         finally
         {
-            await chat.ResetAsync();
+            await agentThread.DeleteAsync();
             await this.AssistantClient.DeleteAssistantAsync(agent.Id);
         }
     }

Original file line number	Diff line number	Diff line change
`@@ -27,9 +27,7 @@ await this.AssistantClient.CreateAssistantAsync(`
`27`	`27`
`28`	`28`	`// Create the agent`
`29`	`29`	`OpenAIAssistantAgent agent = new(assistant, this.AssistantClient);`
`30`		`-`
`31`		`- // Create a chat for agent interaction.`
`32`		`- AgentGroupChat chat = new();`
	`30`	`+ AgentThread? agentThread = null;`
`33`	`31`
`34`	`32`	`// Respond to user input`
`35`	`33`	`try`
`@@ -50,20 +48,26 @@ Sum 426 1622 856 2904`
`50`	`48`	`}`
`51`	`49`	`finally`
`52`	`50`	`{`
	`51`	`+ if (agentThread is not null)`
	`52`	`+ {`
	`53`	`+ await agentThread.DeleteAsync();`
	`54`	`+ }`
	`55`	`+`
`53`	`56`	`await this.AssistantClient.DeleteAssistantAsync(agent.Id);`
`54`	`57`	`}`
`55`	`58`
`56`	`59`	`// Local function to invoke agent and display the conversation messages.`
`57`	`60`	`async Task InvokeAgentAsync(string input)`
`58`	`61`	`{`
`59`	`62`	`ChatMessageContent message = new(AuthorRole.User, input);`
`60`		`- chat.AddChatMessage(message);`
`61`	`63`	`this.WriteAgentChatMessage(message);`
`62`	`64`
`63`		`- await foreach (ChatMessageContent response in chat.InvokeAsync(agent))`
	`65`	`+ await foreach (AgentResponseItem<ChatMessageContent> response in agent.InvokeAsync(message))`
`64`	`66`	`{`
`65`	`67`	`this.WriteAgentChatMessage(response);`
`66`	`68`	`await this.DownloadResponseImageAsync(response);`
	`69`	`+`
	`70`	`+ agentThread = response.Thread;`
`67`	`71`	`}`
`68`	`72`	`}`
`69`	`73`	`}`
Original file line number	Diff line number	Diff line change
`@@ -29,9 +29,7 @@ await this.AssistantClient.CreateAssistantAsync(`
`29`	`29`
`30`	`30`	`// Create the agent`
`31`	`31`	`OpenAIAssistantAgent agent = new(assistant, this.AssistantClient);`
`32`		`-`
`33`		`- // Create a chat for agent interaction.`
`34`		`- AgentGroupChat chat = new();`
	`32`	`+ AgentThread? agentThread = null;`
`35`	`33`
`36`	`34`	`// Respond to user input`
`37`	`35`	`try`
`@@ -42,6 +40,11 @@ await this.AssistantClient.CreateAssistantAsync(`
`42`	`40`	`}`
`43`	`41`	`finally`
`44`	`42`	`{`
	`43`	`+ if (agentThread is not null)`
	`44`	`+ {`
	`45`	`+ await agentThread.DeleteAsync();`
	`46`	`+ }`
	`47`	`+`
`45`	`48`	`await this.AssistantClient.DeleteAssistantAsync(agent.Id);`
`46`	`49`	`await this.Client.DeleteFileAsync(fileId);`
`47`	`50`	`}`
`@@ -50,13 +53,14 @@ await this.AssistantClient.CreateAssistantAsync(`
`50`	`53`	`async Task InvokeAgentAsync(string input)`
`51`	`54`	`{`
`52`	`55`	`ChatMessageContent message = new(AuthorRole.User, input);`
`53`		`- chat.AddChatMessage(new(AuthorRole.User, input));`
`54`	`56`	`this.WriteAgentChatMessage(message);`
`55`	`57`
`56`		`- await foreach (ChatMessageContent response in chat.InvokeAsync(agent))`
	`58`	`+ await foreach (AgentResponseItem<ChatMessageContent> response in agent.InvokeAsync(message))`
`57`	`59`	`{`
`58`	`60`	`this.WriteAgentChatMessage(response);`
`59`	`61`	`await this.DownloadResponseContentAsync(response);`
	`62`	`+`
	`63`	`+ agentThread = response.Thread;`
`60`	`64`	`}`
`61`	`65`	`}`
`62`	`66`	`}`
Original file line number	Diff line number	Diff line change
`@@ -62,46 +62,42 @@ public async Task UseAutoFunctionInvocationFilterWithStreamingAgentInvocationAsy`
`62`	`62`
`63`	`63`	`private async Task InvokeAssistantAsync(OpenAIAssistantAgent agent)`
`64`	`64`	`{`
`65`		`- // Create a thread for the agent conversation.`
`66`		`- AgentGroupChat chat = new();`
	`65`	`+ OpenAIAssistantAgentThread agentThread = new(this.AssistantClient);`
`67`	`66`
`68`	`67`	`try`
`69`	`68`	`{`
`70`	`69`	`// Respond to user input, invoking functions where appropriate.`
`71`	`70`	`ChatMessageContent message = new(AuthorRole.User, "What is the special soup?");`
`72`		`- chat.AddChatMessage(message);`
`73`		`- await chat.InvokeAsync(agent).ToArrayAsync();`
	`71`	`+ await agent.InvokeAsync(message, agentThread).ToArrayAsync();`
`74`	`72`
`75`	`73`	`// Display the entire chat history.`
`76`		`- ChatMessageContent[] history = await chat.GetChatMessagesAsync().Reverse().ToArrayAsync();`
	`74`	`+ ChatMessageContent[] history = await agentThread.GetMessagesAsync(MessageCollectionOrder.Ascending).ToArrayAsync();`
`77`	`75`	`this.WriteChatHistory(history);`
`78`	`76`	`}`
`79`	`77`	`finally`
`80`	`78`	`{`
`81`		`- await chat.ResetAsync();`
	`79`	`+ await agentThread.DeleteAsync();`
`82`	`80`	`await this.AssistantClient.DeleteAssistantAsync(agent.Id);`
`83`	`81`	`}`
`84`	`82`	`}`
`85`	`83`
`86`	`84`	`private async Task InvokeAssistantStreamingAsync(OpenAIAssistantAgent agent)`
`87`	`85`	`{`
`88`		`- // Create a thread for the agent conversation.`
`89`		`- AgentGroupChat chat = new();`
	`86`	`+ OpenAIAssistantAgentThread agentThread = new(this.AssistantClient);`
`90`	`87`
`91`	`88`	`try`
`92`	`89`	`{`
`93`	`90`	`// Respond to user input, invoking functions where appropriate.`
`94`	`91`	`ChatMessageContent message = new(AuthorRole.User, "What is the special soup?");`
`95`		`- chat.AddChatMessage(message);`
`96`		`- await chat.InvokeStreamingAsync(agent).ToArrayAsync();`
	`92`	`+ await agent.InvokeStreamingAsync(message, agentThread).ToArrayAsync();`
`97`	`93`
`98`	`94`	`// Display the entire chat history.`
`99`		`- ChatMessageContent[] history = await chat.GetChatMessagesAsync().Reverse().ToArrayAsync();`
	`95`	`+ ChatMessageContent[] history = await agentThread.GetMessagesAsync(MessageCollectionOrder.Ascending).ToArrayAsync();`
`100`	`96`	`this.WriteChatHistory(history);`
`101`	`97`	`}`
`102`	`98`	`finally`
`103`	`99`	`{`
`104`		`- await chat.ResetAsync();`
	`100`	`+ await agentThread.DeleteAsync();`
`105`	`101`	`await this.AssistantClient.DeleteAssistantAsync(agent.Id);`
`106`	`102`	`}`
`107`	`103`	`}`