diff --git a/dotnet/src/Microsoft.Agents.AI.DurableTask/Microsoft.Agents.AI.DurableTask.csproj b/dotnet/src/Microsoft.Agents.AI.DurableTask/Microsoft.Agents.AI.DurableTask.csproj index 032ba5688d..77c877939e 100644 --- a/dotnet/src/Microsoft.Agents.AI.DurableTask/Microsoft.Agents.AI.DurableTask.csproj +++ b/dotnet/src/Microsoft.Agents.AI.DurableTask/Microsoft.Agents.AI.DurableTask.csproj @@ -17,7 +17,6 @@ - true true diff --git a/dotnet/src/Microsoft.Agents.AI.DurableTask/Workflows/DurableActivityExecutor.cs b/dotnet/src/Microsoft.Agents.AI.DurableTask/Workflows/DurableActivityExecutor.cs index e3ad1980e7..c9e9a1b125 100644 --- a/dotnet/src/Microsoft.Agents.AI.DurableTask/Workflows/DurableActivityExecutor.cs +++ b/dotnet/src/Microsoft.Agents.AI.DurableTask/Workflows/DurableActivityExecutor.cs @@ -4,6 +4,7 @@ using System.Diagnostics.CodeAnalysis; using System.Text.Json; using Microsoft.Agents.AI.Workflows; using Microsoft.Agents.AI.Workflows.Checkpointing; +using Microsoft.Agents.AI.Workflows.Observability; namespace Microsoft.Agents.AI.DurableTask.Workflows; @@ -45,10 +46,11 @@ internal static class DurableActivityExecutor object typedInput = DeserializeInput(executorInput, inputType); DurableWorkflowContext workflowContext = new(sharedState, executor); - object? result = await executor.ExecuteAsync( + object? result = await executor.ExecuteCoreAsync( typedInput, new TypeId(inputType), workflowContext, + WorkflowTelemetryContext.Disabled, cancellationToken).ConfigureAwait(false); return SerializeActivityOutput(result, workflowContext); diff --git a/dotnet/src/Microsoft.Agents.AI.DurableTask/Workflows/DurableExecutorDispatcher.cs b/dotnet/src/Microsoft.Agents.AI.DurableTask/Workflows/DurableExecutorDispatcher.cs index afb7a774fb..ce68b5c0d9 100644 --- a/dotnet/src/Microsoft.Agents.AI.DurableTask/Workflows/DurableExecutorDispatcher.cs +++ b/dotnet/src/Microsoft.Agents.AI.DurableTask/Workflows/DurableExecutorDispatcher.cs @@ -151,7 +151,7 @@ internal static class DurableExecutorDispatcher return $"Agent '{agentName}' not found"; } - AgentSession session = await agent.GetNewSessionAsync().ConfigureAwait(true); + AgentSession session = await agent.CreateSessionAsync().ConfigureAwait(true); AgentResponse response = await agent.RunAsync(input, session).ConfigureAwait(true); return response.Text;