Files
agent-framework/dotnet/src/Microsoft.Agents.AI.Workflows/Checkpointing/CheckpointInfoConverter.cs
T
Jacob Alber 0086d38f58 .NET: [BREAKING] Workflows API Review Naming Changes (Part 1?) (#4090)
* 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>
2026-02-20 02:05:18 +00:00

50 lines
2.1 KiB
C#

// Copyright (c) Microsoft. All rights reserved.
using System.Diagnostics.CodeAnalysis;
using System.Text.Json;
using System.Text.Json.Serialization.Metadata;
using System.Text.RegularExpressions;
namespace Microsoft.Agents.AI.Workflows.Checkpointing;
/// <summary>
/// Provides support for using <see cref="CheckpointInfo"/> values as dictionary keys when serializing and deserializing JSON.
/// </summary>
internal sealed partial class CheckpointInfoConverter() : JsonConverterDictionarySupportBase<CheckpointInfo>
{
protected override JsonTypeInfo<CheckpointInfo> TypeInfo
=> WorkflowsJsonUtilities.JsonContext.Default.CheckpointInfo;
private const string CheckpointInfoPropertyNamePattern = @"^(?<sessionId>(((\|\|)|([^\|]))*))\|(?<checkpointId>(((\|\|)|([^\|]))*)?)$";
#if NET
[GeneratedRegex(CheckpointInfoPropertyNamePattern, RegexOptions.CultureInvariant | RegexOptions.ExplicitCapture)]
public static partial Regex CheckpointInfoPropertyNameRegex();
#else
public static Regex CheckpointInfoPropertyNameRegex() => s_scopeKeyPropertyNameRegex;
private static readonly Regex s_scopeKeyPropertyNameRegex =
new(CheckpointInfoPropertyNamePattern, RegexOptions.Compiled | RegexOptions.CultureInvariant | RegexOptions.ExplicitCapture);
#endif
protected override CheckpointInfo Parse(string propertyName)
{
Match scopeKeyPatternMatch = CheckpointInfoPropertyNameRegex().Match(propertyName);
if (!scopeKeyPatternMatch.Success)
{
throw new JsonException($"Invalid CheckpointInfo property name format. Got '{propertyName}'.");
}
string sessionId = scopeKeyPatternMatch.Groups["sessionId"].Value;
string checkpointId = scopeKeyPatternMatch.Groups["checkpointId"].Value;
return new(Unescape(sessionId)!, Unescape(checkpointId)!);
}
protected override string Stringify([DisallowNull] CheckpointInfo value)
{
string? sessionIdEscaped = Escape(value.SessionId);
string? checkpointIdEscaped = Escape(value.CheckpointId);
return $"{sessionIdEscaped}|{checkpointIdEscaped}";
}
}