mirror of
https://github.com/microsoft/agent-framework.git
synced 2026-06-16 21:04:09 +08:00
899d8ff775
Concurrent run support was recently added to workflows, but Orchestrations did not fully update to support it. A few executors were missing Cross-Run Shareable annotations, and the ConcurrentEnd executor needed to be factory-instantiated. This also ports the fix for #1613 from #1637, to avoid waiting on that PR.
41 lines
1.4 KiB
C#
41 lines
1.4 KiB
C#
// Copyright (c) Microsoft. All rights reserved.
|
|
|
|
using System.Collections.Generic;
|
|
using System.IO;
|
|
using System.Threading.Tasks;
|
|
using Microsoft.Agents.AI.Workflows.UnitTests;
|
|
using Microsoft.Extensions.AI;
|
|
|
|
namespace Microsoft.Agents.AI.Workflows.Sample;
|
|
|
|
internal static class Step10EntryPoint
|
|
{
|
|
public static Workflow CreateWorkflow()
|
|
{
|
|
TestEchoAgent echoAgent = new("echo", "Echo");
|
|
return AgentWorkflowBuilder.BuildSequential(echoAgent);
|
|
}
|
|
public static Workflow WorkflowInstance => CreateWorkflow();
|
|
|
|
public static async ValueTask RunAsync(TextWriter writer, IWorkflowExecutionEnvironment executionEnvironment, IEnumerable<string> inputs)
|
|
{
|
|
AIAgent hostAgent = WorkflowInstance.AsAgent("echo-workflow", "EchoW", executionEnvironment: executionEnvironment);
|
|
|
|
AgentThread thread = hostAgent.GetNewThread();
|
|
foreach (string input in inputs)
|
|
{
|
|
AgentRunResponse response;
|
|
object? continuationToken = null;
|
|
do
|
|
{
|
|
response = await hostAgent.RunAsync(input, thread, new AgentRunOptions { ContinuationToken = continuationToken });
|
|
} while ((continuationToken = response.ContinuationToken) is { });
|
|
|
|
foreach (ChatMessage message in response.Messages)
|
|
{
|
|
writer.WriteLine($"{message.AuthorName}: {message.Text}");
|
|
}
|
|
}
|
|
}
|
|
}
|