使用Azure功能取消带有重试的任务数组

Question

我正在使用Azure功能V4。在编排（mycustomorChestration）中，我会进行粉丝，然后调用Activity trigtiged function（handlefunction）。粉丝出口通常包含约20个任务。 handlefunction用a retryoptions调用，并且可以投掷不同的异常。如果抛出任何例外，则重试应重试，除了mycustomerror。如果mycustomError丢弃所有任务，则应停止重试，无论他们可能会丢下什么例外。我似乎没有工作。恢复不断重试。

我找不到传递concellationToken的方法。而且，如果我在handle中设置一个变量，则将在重播过程中重置。

完整可再现的示例下面：

public class MyCustomError : Exception
{

}

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

    [FunctionName(nameof(HandleIdFunction))]
    public static async Task HandleIdFunction([ActivityTrigger] IDurableActivityContext context)
    {
        var input = context.GetInput<int>();
        Console.WriteLine($"{nameof(HandleIdFunction)} - {input}.");
        await Task.Delay(1000);
        // Fake errors.
        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 parallelTasks = new List<Task<Guid>>();

        var retryOptions = new RetryOptions(TimeSpan.FromSeconds(5), 30)
        {
            BackoffCoefficient = 1.85,
            MaxRetryInterval = TimeSpan.FromSeconds(5),
            RetryTimeout = TimeSpan.FromMinutes(1),
            Handle = exception =>
            {
                Console.WriteLine("Retry handled called");
                return (exception.InnerException is not MyCustomError);
            }
        };

        int[] idBatch = Enumerable.Range(0, 20).ToArray();
        for (int i = 0; i < idBatch.Length; i++)
        {
            var id = idBatch[i];
            Task<Guid> task = context.CallActivityWithRetryAsync<Guid>(nameof(HandleIdFunction), retryOptions, id);
            parallelTasks.Add(task);
        }

        Guid[] result = null;

        try
        {
            result = await Task.WhenAll(parallelTasks);
        }
        catch (Exception ex) when (ex.InnerException is MyCustomError)
        {
            // Custom handling.
        }
        catch (Exception ex)
        {
            // Custom handling.
        }
    }
}