agent/agent-framework
1
0
Fork 0
mirror of https://github.com/microsoft/agent-framework.git synced 2026-06-16 21:04:09 +08:00
Code Issues Packages Projects Releases Wiki Activity

Cleanup

Browse Source
This commit is contained in:
Shyju Krishnankutty
2026-01-26 09:44:08 -08:00
Unverified
parent d98520d0ca
commit cf6e0070b4
2 changed files with 22 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
dotnet/src/Microsoft.Agents.AI.DurableTask/WorkflowHelper.cs
+1 -1
View File
@@ -65,7 +65,7 @@ public static class WorkflowHelper
Dictionary<string, ExecutorBinding> executors = workflow.ReflectExecutors();
Dictionary<string, HashSet<EdgeInfo>> edges = workflow.ReflectEdges();
Dictionary<(string SourceId, string TargetId), Func<object?, bool>?> edgeConditions = workflow.GetEdgeConditions();
Dictionary<(string SourceId, string TargetId), Func<object?, bool>?> edgeConditions = workflow.ReflectEdgeConditions();
WorkflowExecutionPlan plan = new();
dotnet/src/Microsoft.Agents.AI.Workflows/Workflow.cs
+21 -10
View File
@@ -37,20 +37,31 @@ public class Workflow
}
/// <summary>
/// Gets the condition functions for direct edges, keyed by (sourceId, targetId) tuple.
/// Gets a mapping of edge identifiers to their associated condition delegates.
/// </summary>
/// <returns>A dictionary mapping edge connections to their condition functions (null if no condition).</returns>
/// <remarks>This method creates a new dictionary each time it is called to ensure thread safety.</remarks>
[System.Diagnostics.CodeAnalysis.SuppressMessage("Design", "CA1024:Use properties where appropriate", Justification = "Method creates a new collection on each call.")]
public Dictionary<(string SourceId, string TargetId), Func<object?, bool>?> GetEdgeConditions()
/// <remarks>The returned dictionary includes only edges that have direct edge data. The condition
/// delegate can be used to determine whether the edge is active or valid for a given input. Edges without direct
/// edge data are not included in the result.</remarks>
/// <returns>A dictionary where each key is a tuple containing the source and target node identifiers, and each value is a
/// delegate that evaluates the condition for the corresponding edge. The value is <see langword="null"/> if the
/// edge has no associated condition.</returns>
[System.Diagnostics.CodeAnalysis.SuppressMessage("Design", "CA1024:Use properties where appropriate", Justification = "<Pending>")]
public Dictionary<(string SourceId, string TargetId), Func<object?, bool>?> ReflectEdgeConditions()
{
Dictionary<(string SourceId, string TargetId), Func<object?, bool>?> conditions = [];
foreach (KeyValuePair<string, HashSet<Edge>> edgeGroup in this.Edges)
int capacity = 0;
foreach (HashSet<Edge> edgeSet in this.Edges.Values)
{
foreach (Edge edge in edgeGroup.Value)
capacity += edgeSet.Count;
}
Dictionary<(string SourceId, string TargetId), Func<object?, bool>?> conditions = new(capacity);
foreach (HashSet<Edge> edgeSet in this.Edges.Values)
{
foreach (Edge edge in edgeSet)
{
if (edge.DirectEdgeData is DirectEdgeData directEdge)
DirectEdgeData? directEdge = edge.DirectEdgeData;
if (directEdge is not null)
{
conditions[(directEdge.SourceId, directEdge.SinkId)] = directEdge.Condition;
}