Attempt to implement distributed tasks with moleculer
id : site#id name: customer task name input/output: s3 filename status: input|output|work|error|wait submitTime startTime duration tries priority hostname: hostname on which worker did the job, this is not relevant for subtasks
status:
- input => work
- work => output if task success
- work => input if task failed and tries < 10
- work => error if task failed and tries >= 10 TODO: - work => wait if task return childs
Entrypoint for external call is api.
task.id => site#id
- api.createTask(stream, meta { task })
- api.deleteTask
- api.statusTask
- api.resultTask
return { result: "success|failure", err: (null|err) }
test