mirror of
https://github.com/microsoft/agent-framework.git
synced 2026-06-16 21:04:09 +08:00
0086d38f58
* refactor: Normalize Run/RunStreaming with AIAgent * refactor: Clarify Session vs. Run -level concepts * Rename RunId to SessionId to better match Run/Session terminology in AIAgent * [BREAKING]: Will break existing checkpointed sessions in CosmosDb due to field rename * refactor: Rename and simplify interface around getting typed data out of ExternalRequest/Response * Also adds hints around using value types in PortableValue * refactor: Rename AddFanInEdge to AddFanInBarrierEdge This will prevent a breaking change later when we introduce a programmable FanIn edge, analogous to the FanOut edge's EdgeSelector. The goal, in the long run is to support a number of different FanIn scenarios, with naive FanIn (no barrier) by default, similar to FanOut. * refactor: AsAgent(this Workflow, ...) => AsAIAgent(...) * misc - part1: SwitchBuilder internal --------- Co-authored-by: Dmytro Struk <13853051+dmytrostruk@users.noreply.github.com>
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.AsAIAgent("echo-workflow", "EchoW", executionEnvironment: executionEnvironment);
|
|
|
|
AgentSession session = await hostAgent.CreateSessionAsync();
|
|
foreach (string input in inputs)
|
|
{
|
|
AgentResponse response;
|
|
ResponseContinuationToken? continuationToken = null;
|
|
do
|
|
{
|
|
response = await hostAgent.RunAsync(input, session, new AgentRunOptions { ContinuationToken = continuationToken });
|
|
} while ((continuationToken = response.ContinuationToken) is { });
|
|
|
|
foreach (ChatMessage message in response.Messages)
|
|
{
|
|
writer.WriteLine($"{message.AuthorName}: {message.Text}");
|
|
}
|
|
}
|
|
}
|
|
}
|