Является ли моя устойчивая функция Azure детерминированной?

Я новичок в устойчивых функциях Azure и хочу проверить свое понимание того, что значит быть детерминированным.

Поток примерно такой:

1. На основе заданной контрольной даты отметьте записи, которые необходимо обработать, в таблице базы данных A.
2. Создайте и верните данные «события» для отмеченных записей.
3. Обрабатывайте эти события параллельно (разветвление). Некоторые события приведут к записи данных в таблицу базы данных B.
4. После того, как все события обработаны (расширение), сгенерируйте экспорт из данных, записанных в таблицу базы данных B.

Мой текущий подход соответствует строкам кода ниже. Однако, чем больше я об этом думаю, тем больше мне кажется, что мой нынешний подход не является детерминированным. Записи, помеченные в таблице A первым действием, могут больше не помечаться, если вы запустите действие через некоторое время (например, запись больше не соответствует критериям для пометки). Это означало бы, что список, возвращаемый вторым действием, также может отличаться, если данные в таблице A изменились.

Будет ли достаточно изменить мое первое действие, чтобы оно возвращало идентификаторы отмеченных записей в таблице A и использовать этот список в качестве входных данных для второго действия? Для меня это похоже на этот пример:

https://learn.microsoft.com/en-us/azure/azure-functions/durable/durable-functions-cloud-backup?tabs=csharp#e2_backupsitecontent-orchestrator-function

Что я действительно не понимаю во всем этом, если вы повторно запустите пример в документах Microsoft, E2_GetFileList потенциально может вернуть разные файлы, потому что новые файлы могут быть добавлены или существующие удалены. Так как же это детерминировано?

public class DeterministicOrchestrator
{
    [Function("DeterministicOrchestratorApi")]
    public async Task<HttpResponseData> RunApi(
        [HttpTrigger] HttpRequestData request,
        [DurableClient] DurableTaskClient durableTaskClient)
    {
        var referenceDate = new DateOnly(2023, 4, 3);

        var orchestrationInstanceId = await durableTaskClient
            .ScheduleNewOrchestrationInstanceAsync("DeterministicOrchestrator", referenceDate)
            .ConfigureAwait(false);

        return durableTaskClient.CreateCheckStatusResponse(request, orchestrationInstanceId);
    }

    [Function("DeterministicOrchestrator")]
    public async Task Run(
        [OrchestrationTrigger] TaskOrchestrationContext taskOrchestrationContext,
        DateOnly referenceDate)
    {
        var wrappedDateOnly = new WrappedDateOnly { DateOnly = referenceDate };

        await taskOrchestrationContext
            .CallActivityAsync("FlagDatabaseEntries", wrappedDateOnly)
            .ConfigureAwait(true);

        var events = await taskOrchestrationContext
            .CallActivityAsync<string[]>("CreateEvents", wrappedDateOnly)
            .ConfigureAwait(true);

        // Fan-out/fan-in
        var eventTasks = events
            .Select(x => taskOrchestrationContext.CallActivityAsync("ProcessEvent", input: x))
            .ToList();
        await Task.WhenAll(eventTasks).ConfigureAwait(true);

        await taskOrchestrationContext
            .CallActivityAsync("Export", wrappedDateOnly)
            .ConfigureAwait(true);
    }

    [Function("FlagDatabaseEntries")]
    public Task FlagDatabaseEntries([ActivityTrigger] WrappedDateOnly referenceDate)
    {
        // Flags entries in database table A to be processed using given referenceDate.
        return Task.CompletedTask;
    }

    [Function("CreateEvents")]
    public Task<string[]> CreateEvents([ActivityTrigger] DateOnly referenceDate)
    {
        // Creates events based on the entries flagged in the database by previous activity.
        return Task.FromResult(Array.Empty<string>());
    }

    [Function("ProcessEvent")]
    public Task ProcessEvent([ActivityTrigger] string eventToProcess)
    {
        // Process event and some of the events result in data being added to database table B.
        return Task.CompletedTask;
    }

    [Function("Export")]
    public Task Export([ActivityTrigger] DateOnly referenceDate)
    {
        // Export data from the database populated by processing the events.
        return Task.CompletedTask;
    }
}

public class WrappedDateOnly
{
    public DateOnly DateOnly { get; set; }
}