agent/agent-framework
2
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

Add diag logging to findout CI test failure.

Browse Source
This commit is contained in:
Shyju Krishnankutty
2026-03-12 15:39:57 -07:00
parent 5beb0418d3
commit f750cad639
3 changed files with 61 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
dotnet/samples/04-hosting/DurableWorkflows/ConsoleApps/06_WorkflowSharedState/Executors.cs
+17
View File
@@ -38,6 +38,23 @@ internal sealed class ValidateOrder() : Executor<string, OrderDetails>("Validate
string message,
IWorkflowContext context,
CancellationToken cancellationToken = default)
{
try
{
return await HandleAsyncCore(message, context, cancellationToken);
}
catch (Exception ex)
{
Console.Error.WriteLine($"[DIAG] ValidateOrder.HandleAsync failed: {ex.GetType().FullName}: {ex.Message}");
Console.Error.WriteLine($"[DIAG] StackTrace: {ex.StackTrace}");
throw;
}
}
private async ValueTask<OrderDetails> HandleAsyncCore(
string message,
IWorkflowContext context,
CancellationToken cancellationToken = default)
{
await Task.Delay(TimeSpan.FromMilliseconds(200), cancellationToken);
dotnet/src/Microsoft.Agents.AI.DurableTask/Workflows/DurableActivityExecutor.cs
+39 -7
View File
@@ -46,14 +46,46 @@ internal static class DurableActivityExecutor
object typedInput = DeserializeInput(executorInput, inputType);
DurableWorkflowContext workflowContext = new(sharedState, executor);
object? result = await executor.ExecuteCoreAsync(
typedInput,
new TypeId(inputType),
workflowContext,
WorkflowTelemetryContext.Disabled,
cancellationToken).ConfigureAwait(false);
return SerializeActivityOutput(result, workflowContext);
object? result;
try
{
result = await executor.ExecuteCoreAsync(
typedInput,
new TypeId(inputType),
workflowContext,
WorkflowTelemetryContext.Disabled,
cancellationToken).ConfigureAwait(false);
}
catch (Exception ex)
{
// Diagnostic logging to surface inner exception details in CI
Console.Error.WriteLine($"[DIAG] DurableActivityExecutor: ExecuteCoreAsync failed for '{binding.Id}' (inputType={inputType.FullName})");
Console.Error.WriteLine($"[DIAG] Exception: {ex.GetType().FullName}: {ex.Message}");
for (Exception? inner = ex.InnerException; inner is not null; inner = inner.InnerException)
{
Console.Error.WriteLine($"[DIAG] Inner: {inner.GetType().FullName}: {inner.Message}");
Console.Error.WriteLine($"[DIAG] StackTrace: {inner.StackTrace}");
}
throw;
}
string serialized;
try
{
serialized = SerializeActivityOutput(result, workflowContext);
}
catch (Exception ex)
{
Console.Error.WriteLine($"[DIAG] DurableActivityExecutor: SerializeActivityOutput failed for '{binding.Id}'");
Console.Error.WriteLine($"[DIAG] Result type: {result?.GetType().FullName ?? "null"}");
Console.Error.WriteLine($"[DIAG] Exception: {ex.GetType().FullName}: {ex.Message}");
Console.Error.WriteLine($"[DIAG] StackTrace: {ex.StackTrace}");
throw;
}
return serialized;
}
private static string SerializeActivityOutput(object? result, DurableWorkflowContext context)
dotnet/src/Microsoft.Agents.AI.Workflows/Executor.cs
+5 -1
View File
@@ -284,7 +284,11 @@ public abstract class Executor : IIdentified
if (!result.IsSuccess)
{
throw new TargetInvocationException($"Error invoking handler for {message.GetType()}", result.Exception);
// Include inner exception details for diagnostics (otherwise hidden by DTS FailureDetails)
string innerDetails = result.Exception is not null
? $" --> {result.Exception.GetType().Name}: {result.Exception.Message}"
: string.Empty;
throw new TargetInvocationException($"Error invoking handler for {message.GetType()}{innerDetails}", result.Exception);
}
if (result.IsVoid)