Durable Function嵌套循环扇出调用TaskList时外层循环重复执行问题

根本原因 #

Durable Function编排器自带执行重放机制：每次await异步操作（比如活动调用、Timer等）完成后，编排器都会从头重新执行整个函数代码，通过重放历史事件恢复上下文状态。
你当前代码中所有的状态变量hashKeyList、tasksList、otherCalc、finalResults都是在编排器内部初始化的本地可变变量，每次重放时都会被重新实例化清空之前的内容，导致：

• 之前已经计算过的hashKey丢失，所有a、b组合都会命中else分支存入otherCalc
• 每次重放都会从头遍历外层循环A的所有元素，看起来就像外层循环被多次触发

修复方案 #

首先要遵守编排器代码的确定性规则：所有跨重放需要保留的状态不能依赖本地可变变量，要么通过上下文持久化存储，要么可以通过重放历史确定性重建。
修正后的代码示例如下：

[FunctionName("Orchestrator")]
public static async Task<bool> RunOrchestrator(
[OrchestrationTrigger] IDurableOrchestrationContext context, ILogger logger)
{
    // 仅在第一次执行时初始化跨重放的全局状态，重放时从上下文获取
    var globalState = context.GetInput<GlobalState>() ?? new GlobalState();
    List<Task<CalcResult>> currentLoopTasks = new List<Task<CalcResult>>();

    foreach (var a in A)//LOOP A
    {
        // 每次外层循环开始重置当前轮次的任务列表
        currentLoopTasks.Clear();
        foreach (var b in B)//LOOP B
        {
            // 确保doSomeThingOnAandB是确定性方法，不能包含随机、时间等非确定性逻辑
            var hashKey = doSomeThingOnAandB(a, b);
            if (!globalState.HashKeyList.Contains(hashKey))
            {
                globalState.HashKeyList.Add(hashKey);
                var task = context.CallActivityAsync<CalcResult>(nameof(CalculationActivity), (a, b));
                currentLoopTasks.Add(task);
            }
            else
            {
                globalState.OtherCalc.Add(a, b);
            }
        }
        await Task.WhenAll(currentLoopTasks);

        foreach (var task in currentLoopTasks)
        {
            // 不要用Task.Result，改用await避免死锁，同时符合编排器重放规则
            var res = await task;
            globalState.FinalResults.Add(res);
        }
        // 每次外层循环结束更新上下文持久化状态，重放时会自动恢复
        context.SetCustomStatus(globalState);
    }

    // 最终返回结果
    return true;
}

// 定义全局状态类，用来持久化跨重放的所有数据
public class GlobalState
{
    public List<string> HashKeyList { get; set; } = new List<string>();
    public Dictionary<A, B> OtherCalc { get; set; } = new Dictionary<A, B>();
    public List<FinalResult> FinalResults { get; set; } = new List<FinalResult>();
}

额外注意事项 #

• 确保doSomeThingOnAandB方法是完全确定性的：输入相同的a、b必须输出相同的hashKey，不能包含DateTime.Now、随机数、GUID生成等非确定性逻辑，如果需要用到时间，要调用context.CurrentUtcDateTime获取确定性时间。
• 不要在编排器代码中直接修改共享的静态变量，所有需要累计的状态都要存入GlobalState通过上下文持久化。
• 内层循环的任务列表只需要在当前外层循环轮次生效，所以可以作为本地变量每次循环重置，不需要跨重放持久化。

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