Table of Contents |
---|
Responsibility
- Watch resched (queue?) for job-task event.
- Watch resched (queue?) for groom-offline event.
- Watch wait queue, move to processing one.
- Dispatch directive(s)
Procedure
Procedure
- Check taskAssignQueue if empty request Receptionist
- Receive a job from Receptionist
- schedule active tasks to particular GroomServer(s)
- Wait for GroomServer request, from a particular GroomServer's TaskManagerwith GroomServerSpec, for task assignmentassign.
- chec with criteria:
- Check if all tasks for a job is scheduled/ assigned
- if true, move the job to processingQueue else wait for GroomServer request.
- If RescheduledTask event triggered,
No Format |
---|
if active tasks scheduled to the same groom server + to be assigned task > GroomServerSpec.totalSlots skip GroomServer's TaskManager request else dispatch directive(task) |