Differences between revisions 4 and 5
Revision 4 as of 2014-04-29 11:49:56
Size: 641
Editor: ChiaHungLin
Comment:
Revision 5 as of 2014-04-29 14:43:54
Size: 787
Editor: ChiaHungLin
Comment:
Deletions are marked like this. Additions are marked like this.
Line 19: Line 19:
  * Stop all tasks of a job/ jobs
  * Move failed jobs to a temp queue
  * Reschedule (recalculate split, etc.?) tasks for jobs sequentially.

Contents

  1. Procedure

Procedure

  • Check taskAssignQueue if empty request Receptionist
  • Receive a job from Receptionist
  • Wait for GroomServer request, with GroomServerSpec, for task assign.

    if active tasks scheduled to the same groom server + 
       to be assigned task > GroomServerSpec.totalSlots 
      skip GroomServer's TaskManager request
    else
      dispatch directive(task)
  • 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,

    • Stop all tasks of a job/ jobs
    • Move failed jobs to a temp queue
    • Reschedule (recalculate split, etc.?) tasks for jobs sequentially.

Scheduler (last edited 2014-04-29 14:43:54 by ChiaHungLin)