Azure Functions V4配置RetryOptions时如何终止所有并行重试任务

现有实现无法终止重试的核心原因有4点：

• RetryOptions.Handle 是单活动维度的判断委托，仅能控制当前抛出异常的活动是否重试，本身不具备跨并行任务传递终止信号的能力，自然无法停止其他正在运行或重试的活动。
• Durable Functions 编排器遵循确定性重放机制，编排方法内声明的所有局部变量会在每次重放时重新初始化，直接在Handle委托中修改本地状态变量，重放后会被重置，无法持久保留终止标记。
• 代码存在类型不匹配问题：HandleIdFunction 为无返回值的Task类型，调用时却使用了带Guid泛型参数的CallActivityWithRetryAsync<Guid>方法，运行时会抛出类型转换异常，干扰重试逻辑判断。
• 异常判断逻辑存在漏洞：Task.WhenAll和活动调用抛出的异常会被包装为多层嵌套的AggregateException，仅判断第一层InnerException大概率无法捕获到深层嵌套的MyCustomError。

Durable Functions 没有提供直接跨活动传递全局取消信号的原生API，活动函数的CancellationToken由宿主自动注入，不需要手动通过入参传递，可以通过持久化自定义状态+编排器取消令牌源的方式实现全局终止，核心逻辑：

• 用context.SetCustomStatus/context.GetCustomStatus持久化存储致命错误终止标记，该状态独立于编排器重放流程，不会被重置。
• 用context.CreateCancellationTokenSource()创建编排维度的取消令牌源，一旦检测到MyCustomError，立刻触发取消，所有绑定该令牌的活动调用会立即停止执行与重试。
• 所有修改全局状态的逻辑增加IsReplaying判断，避免重放阶段重复执行副作用逻辑导致状态错乱。
• 异常判断时调用Flatten()打平嵌套异常，避免漏判深层的自定义异常。

修正后的可运行代码如下：

public class MyCustomError : Exception
{
}

public static class DurableFunctionExample
{
    [FunctionName("HttpStart")]
    public static async Task<IActionResult> Run(
        [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = null)] HttpRequest req,
        [DurableClient] IDurableClient starter,
        ILogger log)
    {
        var instanceId = await starter.StartNewAsync(nameof(MyCustomOrchestration));
        return new OkObjectResult(instanceId);
    }

    [FunctionName(nameof(HandleIdFunction))]
    public static async Task HandleIdFunction(
        [ActivityTrigger] IDurableActivityContext context, 
        CancellationToken cancellationToken)
    {
        var input = context.GetInput<int>();
        log.LogInformation("{FunctionName} processing input {Input}", nameof(HandleIdFunction), input);
        // 宿主自动注入的取消令牌会响应编排器的终止信号
        await Task.Delay(1000, cancellationToken);
        cancellationToken.ThrowIfCancellationRequested();
        
        // 模拟业务错误
        if (input == 10)
            throw new MyCustomError();
        if (input % 2 == 0)
            throw new Exception("普通业务异常");
    }

    [FunctionName(nameof(MyCustomOrchestration))]
    public static async Task MyCustomOrchestration([OrchestrationTrigger] IDurableOrchestrationContext context)
    {
        // 从持久化状态读取终止标记，重放不会重置该值
        var isTerminated = context.GetCustomStatus<bool?>() ?? false;
        var parallelTasks = new List<Task>();
        // 创建编排维度的持久化取消令牌源
        using var cts = context.CreateCancellationTokenSource();

        var retryOptions = new RetryOptions(TimeSpan.FromSeconds(5), 30)
        {
            BackoffCoefficient = 1.85,
            MaxRetryInterval = TimeSpan.FromSeconds(5),
            RetryTimeout = TimeSpan.FromMinutes(1),
            Handle = exception =>
            {
                // 重放阶段不执行状态修改逻辑，保证编排确定性
                if (context.IsReplaying)
                    return !exception.Flatten().InnerExceptions.Any(e => e is MyCustomError);
                
                // 打平嵌套异常判断是否为致命自定义错误
                var hasFatalError = exception.Flatten().InnerExceptions.Any(e => e is MyCustomError);
                if (hasFatalError)
                {
                    // 写入持久化终止标记
                    context.SetCustomStatus(true);
                    // 触发全局取消
                    cts.Cancel();
                    return false; // 当前任务立即停止重试
                }
                return true; // 普通异常按策略重试
            }
        };

        int[] idBatch = Enumerable.Range(0, 20).ToArray();
        foreach (var id in idBatch)
        {
            // 无返回值活动使用非泛型调用方法，传入取消令牌
            var task = context.CallActivityWithRetryAsync(
                nameof(HandleIdFunction), 
                retryOptions, 
                id, 
                cts.Token);
            parallelTasks.Add(task);
        }

        try
        {
            await Task.WhenAll(parallelTasks);
        }
        catch (Exception ex)
        {
            var flattenedEx = ex.Flatten();
            if (flattenedEx.InnerExceptions.Any(e => e is MyCustomError || e is TaskCanceledException))
            {
                // 致命错误自定义处理逻辑：所有任务已取消，重试已停止
                return;
            }
            // 普通异常自定义处理逻辑
        }
    }
}

• 活动抛出普通异常时，Handle委托返回true，活动按照配置的重试策略正常重试。
• 任意活动抛出MyCustomError时，当前活动立即停止重试，全局取消信号触发后，其余所有并行活动收到令牌通知立即终止，不会再执行后续重试。
• 终止标记持久化存储在编排实例状态中，编排器重放时会读取已保存的状态，不会出现变量重置问题。

内容的提问来源于stack exchange，提问作者smoksnes