diff --git a/dotnet/src/Microsoft.AutoGen/Agents/AgentBaseExtensions.cs b/dotnet/src/Microsoft.AutoGen/Agents/AgentBaseExtensions.cs index 741e24772cb9..38098e5dd9d4 100644 --- a/dotnet/src/Microsoft.AutoGen/Agents/AgentBaseExtensions.cs +++ b/dotnet/src/Microsoft.AutoGen/Agents/AgentBaseExtensions.cs @@ -61,7 +61,7 @@ public static class AgentBaseExtensions public static Activity? ExtractActivity(this AgentBase agent, string activityName, MapField metadata) { - return ExtractActivity(agent, activityName, metadata.ToDictionary(kvp => kvp.Key, kvp => kvp.Value.CeString)); + return ExtractActivity(agent, activityName, metadata.ToDictionary(kvp => kvp.Key, kvp => kvp.Value.CeString)); } /// diff --git a/dotnet/src/Microsoft.AutoGen/Agents/AgentRuntime.cs b/dotnet/src/Microsoft.AutoGen/Agents/AgentRuntime.cs index 28b875936657..2da0d28cf658 100644 --- a/dotnet/src/Microsoft.AutoGen/Agents/AgentRuntime.cs +++ b/dotnet/src/Microsoft.AutoGen/Agents/AgentRuntime.cs @@ -2,11 +2,10 @@ // AgentRuntime.cs using System.Diagnostics; +using Google.Protobuf.Collections; using Microsoft.AutoGen.Abstractions; -using static Microsoft.AutoGen.Abstractions.CloudEvent.Types; using Microsoft.Extensions.Logging; - -using Google.Protobuf.Collections; +using static Microsoft.AutoGen.Abstractions.CloudEvent.Types; namespace Microsoft.AutoGen.Agents; @@ -51,7 +50,7 @@ public void Update(RpcRequest request, Activity? activity = null) } public void Update(CloudEvent cloudEvent, Activity? activity = null) { - DistributedContextPropagator.Inject(activity, cloudEvent.Attributes, static (carrier, key, value) => + DistributedContextPropagator.Inject(activity, cloudEvent.Attributes, static (carrier, key, value) => ((MapField)carrier!)[key].CeString = value); } public async ValueTask SendResponseAsync(RpcRequest request, RpcResponse response, CancellationToken cancellationToken = default)