mirror of
https://github.com/microsoft/agent-framework.git
synced 2026-06-16 21:04:09 +08:00
Jacob Alber
0bf6d437d8
* fix: Workflow Validation * adds orphan validation to workflow builder * adds tests for workflow validation * expands on the underlying reasoning why type validation is not supported * fixup: CodeGen template
88 lines
3.4 KiB
C#
88 lines
3.4 KiB
C#
// ------------------------------------------------------------------------------
|
|
// <auto-generated>
|
|
// This code was generated by a tool.
|
|
// </auto-generated>
|
|
// ------------------------------------------------------------------------------
|
|
|
|
#nullable enable
|
|
#pragma warning disable IDE0005 // Extra using directive is ok.
|
|
|
|
using System;
|
|
using System.Collections;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
using Microsoft.Agents.AI;
|
|
using Microsoft.Agents.AI.Workflows;
|
|
using Microsoft.Agents.AI.Workflows.Declarative;
|
|
using Microsoft.Agents.AI.Workflows.Declarative.Kit;
|
|
using Microsoft.Extensions.AI;
|
|
|
|
namespace Test.WorkflowProviders;
|
|
|
|
/// <summary>
|
|
/// This class provides a factory method to create a <see cref="Workflow" /> instance.
|
|
/// </summary>
|
|
/// <remarks>
|
|
/// The workflow defined here was generated from a declarative workflow definition.
|
|
/// Declarative workflows utilize Power FX for defining conditions and expressions.
|
|
/// To learn more about Power FX, see:
|
|
/// https://learn.microsoft.com/power-platform/power-fx/formula-reference-copilot-studio
|
|
/// </remarks>
|
|
public static class WorkflowProvider
|
|
{
|
|
/// <summary>
|
|
/// The root executor for a declarative workflow.
|
|
/// </summary>
|
|
internal sealed class MyWorkflowRootExecutor<TInput>(
|
|
DeclarativeWorkflowOptions options,
|
|
Func<TInput, ChatMessage> inputTransform) :
|
|
RootExecutor<TInput>("my_workflow_Root", options, inputTransform)
|
|
where TInput : notnull
|
|
{
|
|
protected override async ValueTask ExecuteAsync(TInput message, IWorkflowContext context, CancellationToken cancellationToken)
|
|
{
|
|
// Initialize variables
|
|
await context.QueueStateUpdateAsync("MyTable", UnassignedValue.Instance, "Local").ConfigureAwait(false);
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Assigns an evaluated expression, other variable, or literal value to the "Local.MyTable" variable.
|
|
/// </summary>
|
|
internal sealed class SetVarExecutor(FormulaSession session) : ActionExecutor(id: "set_var", session)
|
|
{
|
|
// <inheritdoc />
|
|
protected override async ValueTask<object?> ExecuteAsync(IWorkflowContext context, CancellationToken cancellationToken)
|
|
{
|
|
object? evaluatedValue = await context.EvaluateValueAsync<object>("[{id: 3}]").ConfigureAwait(false);
|
|
await context.QueueStateUpdateAsync(key: "MyTable", value: evaluatedValue, scopeName: "Local").ConfigureAwait(false);
|
|
|
|
return default;
|
|
}
|
|
}
|
|
|
|
public static Workflow CreateWorkflow<TInput>(
|
|
DeclarativeWorkflowOptions options,
|
|
Func<TInput, ChatMessage>? inputTransform = null)
|
|
where TInput : notnull
|
|
{
|
|
// Create root executor to initialize the workflow.
|
|
inputTransform ??= (message) => DeclarativeWorkflowBuilder.DefaultTransform(message);
|
|
MyWorkflowRootExecutor<TInput> myWorkflowRoot = new(options, inputTransform);
|
|
DelegateExecutor myWorkflow = new(id: "my_workflow", myWorkflowRoot.Session);
|
|
SetVarExecutor setVar = new(myWorkflowRoot.Session);
|
|
|
|
// Define the workflow builder
|
|
WorkflowBuilder builder = new(myWorkflowRoot);
|
|
|
|
// Connect executors
|
|
builder.AddEdge(myWorkflowRoot, myWorkflow);
|
|
builder.AddEdge(myWorkflow, setVar);
|
|
|
|
// Build the workflow
|
|
return builder.Build(validateOrphans: false);
|
|
}
|
|
}
|