Temporal: Когда и как использовать местную активность?

Согласно эта почта,

Вот последовательность шагов для выполнения рабочего процесса одного действия.

1. Запущен рабочий процесс, который добавляет задачу рабочего процесса в задачу рабочего процесса. очередь.
2. Задача рабочего процесса получена работником рабочего процесса, который слушает очередь задач рабочего процесса.
3. Задача рабочего процесса завершается командой ScheduleActivityTask.
4. Задача активности добавляется в очередь задач активности.
5. Задача активности получена работником активности.
6. Оперативная задача выполняется оператором активности.
7. Задача рабочего процесса добавляется в очередь задач рабочего процесса.
8. Задание рабочего процесса с результатом активности получает рабочий рабочий процесс.
9. Задача рабочего процесса завершена с помощью CompleteWorkflowExecution команда.

Вот последовательность шагов для выполнения локального действия.

1. Запущен рабочий процесс, который добавляет задачу рабочего процесса в задачу рабочего процесса. очередь.
2. Задача рабочего процесса получена работником рабочего процесса, который слушает очередь задач рабочего процесса.
3. Рабочий процесс планирует локальную задачу активности во внутрипроцессном локальном очередь задач активности.
4. Локальная активность выполняется локальным рабочим, который слушает в очередь задач локальной активности внутри процесса.
5. Задача локальной активности возвращается в рабочий процесс.
6. Задача рабочего процесса завершена с помощью RecordMarker и CompleteWorkflowExecution команды. Команда маркера содержит результат выполнения локальной деятельности.

Ограничения местных мероприятий:

1. Работает только для коротких действий, которые не выходят за рамки рабочего процесса. Тайм-аут задачи. Это означает, что сердцебиение не поддерживается для местные мероприятия.
2. Это неэффективно для долгих попыток. Нормальная деятельность может быть повторять практически бесконечно.
3. Локальная активность хотя бы раз имеет семантику как сбой рабочего процесса. задача приведет к их повторному выполнению.
4. Локальная активность расширяет выполнение задач рабочего процесса. Пока задача при работе он не может реагировать на сигналы. Таким образом, увеличивается задержка для обработка сигналов.

Предупреждение от @Максим

We’ve seen multiple cases when use of local activities without understanding their limitations caused various production issues. So my advice is to stick to normal activities unless your use case requires very high throughput and large activity fan outs of very short activities.

Пример кода java-sdk:

  private final RetryOptions retryOptions = RetryOptions.newBuilder()
          .setInitialInterval(Duration.ofSeconds(1))
          .setMaximumInterval(Duration.ofSeconds(10))
          .setBackoffCoefficient(2.0)
          .setMaximumAttempts(3)
          .build();

  private final LocalActivityOptions laOptions =
          LocalActivityOptions.newBuilder()
                  .setRetryOptions(retryOptions)
                  .setStartToCloseTimeout(Duration.ofSeconds(10))
                  .build();

  private final Account acc = Workflow.newLocalActivityStub(Account.class, laOptions);