Minor cleanup

dotnet/samples/AzureFunctions/10_WorkflowConcurrent/PrepareQuery.cs

@@ -4,7 +4,7 @@ using Microsoft.Agents.AI.Workflows;
 
 namespace SingleAgent;
 
-internal sealed class ConcurrentStartExecutor() : Executor<string, string>("ConcurrentStartExecutor")
+internal sealed class PrepareQuery() : Executor<string, string>("PrepareQuery")
 {
     public override ValueTask<string> HandleAsync(string message, IWorkflowContext context, CancellationToken cancellationToken = default)
     {
@@ -19,19 +19,11 @@ internal sealed class ConcurrentStartExecutor() : Executor<string, string>("Conc
     }
 }
 
-internal sealed class ResultAggregationExecutor() : Executor<string[], string>("ResultAggregationExecutor")
+internal sealed class ResultAggregator() : Executor<string[], string>("ResultAggregator")
 {
-    /// <summary>
-    /// Handles incoming messages from the agents and aggregates their responses.
-    /// </summary>
-    /// <param name="message">The messages from the parallel agents.</param>
-    /// <param name="context">Workflow context for accessing workflow services and adding events.</param>
-    /// <param name="cancellationToken">The <see cref="CancellationToken"/> to monitor for cancellation requests.
-    /// The default is <see cref="CancellationToken.None"/>.</param>
-    /// <returns>A task representing the asynchronous operation.</returns>
     public override ValueTask<string> HandleAsync(string[] message, IWorkflowContext context, CancellationToken cancellationToken = default)
     {
-        // Aggregate all responses from parallel executors
+        // Aggregate all responses from parallel executors.
         string aggregatedResponse = string.Join("\n---\n", message);
         return ValueTask.FromResult($"Aggregated {message.Length} responses:\n{aggregatedResponse}");
     }

dotnet/samples/AzureFunctions/10_WorkflowConcurrent/Program.cs

@@ -27,8 +27,8 @@ AzureOpenAIClient client = !string.IsNullOrEmpty(azureOpenAiKey)
 AIAgent physicist = client.GetChatClient(deploymentName).CreateAIAgent("You are an expert in physics. You answer questions from a physics perspective.", "Physicist");
 AIAgent chemist = client.GetChatClient(deploymentName).CreateAIAgent("You are an expert in chemistry. You answer questions from a chemistry perspective.", "Chemist");
 
-var startExecutor = new ConcurrentStartExecutor();
-var aggregationExecutor = new ResultAggregationExecutor();
+var startExecutor = new PrepareQuery();
+var aggregationExecutor = new ResultAggregator();
 
 var workflow = new WorkflowBuilder(startExecutor)
     .WithName("ExpertReview")

dotnet/samples/AzureFunctions/10_WorkflowConcurrent/ResponseRouterExecutor.cs

@@ -1,27 +0,0 @@
-//// Copyright (c) Microsoft. All rights reserved.
-
-//using Microsoft.Agents.AI.Workflows;
-
-//namespace SingleAgent;
-
-///// <summary>
-///// Routes survey responses to appropriate teams based on rating and category.
-///// </summary>
-//public sealed class ResponseRouterExecutor() : Executor<string, string>("ResponseRouterExecutor")
-//{
-//    public override ValueTask<string> HandleAsync(string message, IWorkflowContext context, CancellationToken cancellationToken = default)
-//    {
-//        if (message.Contains("billing", StringComparison.OrdinalIgnoreCase))
-//        {
-//            return ValueTask.FromResult("Routed to Billing Team");
-//        }
-//        else if (message.Contains("technical", StringComparison.OrdinalIgnoreCase))
-//        {
-//            return ValueTask.FromResult("Routed to Technical Support Team");
-//        }
-//        else
-//        {
-//            return ValueTask.FromResult("Routed to General Support Team");
-//        }
-//    }
-//}

dotnet/samples/AzureFunctions/10_WorkflowConcurrent/SurveyResponseParserExecutor.cs

@@ -1,82 +0,0 @@
-//// Copyright (c) Microsoft. All rights reserved.
-
-//using System.Text.Json;
-//using System.Text.RegularExpressions;
-//using Microsoft.Agents.AI.Workflows;
-
-//namespace SingleAgent;
-
-///// <summary>
-///// This executor parses survey responses and produces structured output.
-///// Example input: "Rating: 8. The app is good but checkout process is confusing."
-///// </summary>
-//[System.Diagnostics.CodeAnalysis.SuppressMessage("Performance", "CA1812:Avoid uninstantiated internal classes", Justification = "Instantiated by workflow framework")]
-//internal sealed partial class SurveyResponseParserExecutor() : Executor<string, string>("SurveyResponseParserExecutor")
-//{
-//    private static readonly JsonSerializerOptions s_jsonOptions = new()
-//    {
-//        WriteIndented = true
-//    };
-
-//    [GeneratedRegex(@"Rating:\s*(\d+)", RegexOptions.IgnoreCase)]
-//    private static partial Regex RatingRegex();
-
-//    public override ValueTask<string> HandleAsync(string message, IWorkflowContext context, CancellationToken cancellationToken = default)
-//    {
-//        SurveyResponse response = this.ParseSurveyResponse(message);
-//        string jsonResult = JsonSerializer.Serialize(response, s_jsonOptions);
-//        return ValueTask.FromResult(jsonResult);
-//    }
-
-//    private SurveyResponse ParseSurveyResponse(string message)
-//    {
-//        // Parse the message to extract rating and comment
-//        int? rating = null;
-//        string comment = message;
-
-//        // Try to extract rating using pattern "Rating: {number}"
-//        Match ratingMatch = RatingRegex().Match(message);
-//        if (ratingMatch.Success && int.TryParse(ratingMatch.Groups[1].Value, out int parsedRating))
-//        {
-//            rating = parsedRating;
-
-//            // Remove the rating part from the message to get the comment
-//            // Find the position after the rating number
-//            int ratingEndIndex = ratingMatch.Index + ratingMatch.Length;
-
-//            // Skip any separators (period, comma, dash, etc.) and whitespace
-//            while (ratingEndIndex < message.Length &&
-//                   (char.IsWhiteSpace(message[ratingEndIndex]) ||
-//                    message[ratingEndIndex] == '.' ||
-//                    message[ratingEndIndex] == ',' ||
-//                    message[ratingEndIndex] == '-'))
-//            {
-//                ratingEndIndex++;
-//            }
-
-//            if (ratingEndIndex < message.Length)
-//            {
-//                comment = message[ratingEndIndex..].Trim();
-//            }
-//            else
-//            {
-//                comment = string.Empty;
-//            }
-//        }
-
-//        // Create and return the structured response
-//        return new SurveyResponse
-//        {
-//            Rating = rating,
-//            Comment = comment,
-//            OriginalMessage = message
-//        };
-//    }
-
-//    private sealed class SurveyResponse
-//    {
-//        public int? Rating { get; set; }
-//        public string Comment { get; set; } = string.Empty;
-//        public string OriginalMessage { get; set; } = string.Empty;
-//    }
-//}

dotnet/samples/AzureFunctions/11_WorkflowSharedState/OrderIdParserExecutor.cs

@@ -69,7 +69,6 @@ internal sealed class EmailSenderExecutor() : Executor<Order, string>("EmailSend
             SharedStateConstants.MessageScope,
             cancellationToken);
 
-        // Combine with the input message
         return storedMessage is not null
             ? $"From state: [{storedMessage}] | Input: [{message.Id}]"
             : $"No state found | Input: [{message.Id}]";