Любая очередь за состояниями шага - PullRequest
0 голосов
/ 09 января 2019

Есть ли какая-либо очередь или какой-либо способ хранения, который работает за сценой в пошаговой функции для каждого состояния? Например. Скажем, функция шага Конечный автомат запускается лямбда-выражением. С каждым состоянием в State Machine связан опросчик активности. Теперь, скажем, из 10 запросов, поступивших в первое состояние в функции Step, и программа-поллер, связанная с этим состоянием, просто выполняет 1 запрос, и 9 из них все еще ожидают выполнения.

Итак, мой вопрос, где хранятся эти 9 запросов? Правильно ли мое понимание того, как это работает? Если они где-то хранятся, сколько времени они будут храниться?

1 Ответ

0 голосов
/ 14 января 2019

Если я правильно понял, вы имеете в виду, если конечный автомат (SM) выполняется 10 раз, поэтому в каждом SM вызывается первая задача активности. Задача активности каждого выполнения SM будет ожидать ответа от Worker. Задание задачи Рабочий опрос, использующий действие API GetActivityTask, получит 10 ответов input & taskToken от каждого SM отдельно. Рабочий должен включить taskToken в последующие вызовы SendTaskHeartbeat, SendTaskSuccess или SendTaskFailure, чтобы сообщить о ходе или завершении задачи для каждого SM. Состояние активности должно включать TimeoutSeconds, как указано в рекомендациях .

...