0.2.0 • Published 5 years ago
task-attemptor v0.2.0
Task Attemptor
What it does:
- Query all dispatched, un-attempted(currently) tasks that is expected to be attempted before
now()
(usually assigned by task dispatcher) Check the task:
- If the task is outdated: revert the task state into un-dispatched.
- Otherwise: fetch the channel configurations of rate limiting for the expected attempt channel of the task
Generate task attempt:
- On rate limiting unexceeded, create a new instance of
task_attempt
, mark the task asprocing
- On rate limiting unexceeded, create a new instance of
Check if the task is valid for attempting
If task valid for attempting, attempt the task via given task type and task channel
How it runs:
Configuration:
- One instance per
TaskType × Channel
- Envs vars:
APPOINTMENT_SUGGESTION_SERVICE_URL
: the appointment suggestion service url, without protocol header
0.2.0
5 years ago