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

Propagate cancellation token down the stack (#1641)

Browse Source
This commit is contained in:
Peter Ibekwe
2025-10-22 18:44:44 -07:00
committed by GitHub
Unverified
parent 0fc1b8837b
commit e9687d59b4
3 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
dotnet/src/Microsoft.Agents.AI.Workflows.Declarative/Interpreter/DeclarativeActionExecutor.cs
+1 -1
View File
@@ -73,7 +73,7 @@ internal abstract class DeclarativeActionExecutor : Executor<ActionExecutorResul
try
{
object? result = await this.ExecuteAsync(new DeclarativeWorkflowContext(context, this._state), cancellationToken: default).ConfigureAwait(false);
object? result = await this.ExecuteAsync(new DeclarativeWorkflowContext(context, this._state), cancellationToken).ConfigureAwait(false);
Debug.WriteLine($"RESULT #{this.Id} - {result ?? "(null)"}");
if (this.EmitResultEvent)
dotnet/src/Microsoft.Agents.AI.Workflows.Declarative/Kit/ActionExecutor.cs
+1 -1
View File
@@ -75,7 +75,7 @@ public abstract class ActionExecutor<TMessage> : Executor<TMessage>, IResettable
/// <inheritdoc/>
public override async ValueTask HandleAsync(TMessage message, IWorkflowContext context, CancellationToken cancellationToken)
{
object? result = await this.ExecuteAsync(new DeclarativeWorkflowContext(context, this._session.State), message, cancellationToken: default).ConfigureAwait(false);
object? result = await this.ExecuteAsync(new DeclarativeWorkflowContext(context, this._session.State), message, cancellationToken).ConfigureAwait(false);
Debug.WriteLine($"RESULT #{this.Id} - {result ?? "(null)"}");
await context.SendResultMessageAsync(this.Id, result, cancellationToken).ConfigureAwait(false);
dotnet/src/Microsoft.Agents.AI.Workflows.Declarative/Kit/IWorkflowContextExtensions.cs
+1 -1
View File
@@ -53,7 +53,7 @@ public static class IWorkflowContextExtensions
/// </example>
public static async ValueTask<string> FormatTemplateAsync(this IWorkflowContext context, IEnumerable<string> lines, CancellationToken cancellationToken = default)
{
WorkflowFormulaState state = await context.GetStateAsync(cancellationToken: default).ConfigureAwait(false);
WorkflowFormulaState state = await context.GetStateAsync(cancellationToken).ConfigureAwait(false);
StringBuilder builder = new();
foreach (string line in lines)