feat(scheduler): support routine based scheduling; support Priority/Elder/Depends

dynamic scheduling; add some test scripts

Author: Ethereal-O

vermeer/apps/graphio/local_file.go

@@ -82,6 +82,7 @@ func (a *LocalMaker) MakeTasks(params map[string]string, taskID int32) ([]LoadPa
 			logrus.Errorf(s)
 			return nil, errors.New(s)
 		}
+		logrus.Debugf("MakeTask LoadTypeLocal parse file: %s, s:%d, e:%d", files, s, e)
 		for i := s; i <= e; i++ {
 			part := LoadPartition{}
 			part.Init(partID, taskID, LoadPartTypeVertex)

vermeer/apps/master/bl/grpc_handlers.go

@@ -26,6 +26,7 @@ import (
 	"time"
 	"vermeer/apps/compute"
 	"vermeer/apps/graphio"
+	"vermeer/apps/master/schedules"
 	"vermeer/apps/master/threshold"
 	"vermeer/apps/master/workers"
 	pb "vermeer/apps/protos"
@@ -99,6 +100,7 @@ func (h *ServerHandler) SayHelloMaster(ctx context.Context, req *pb.HelloMasterR
 	}
 
 	_, err = workerMgr.AddWorker(reqWorker)
+	Scheduler.ChangeWorkerStatus(reqWorker.Name, schedules.WorkerOngoingStatusIdle)
 	if err != nil {
 		logrus.Errorf("failed to add a WorkerClient to the WorkerManager, error: %s", err)
 		return &pb.HelloMasterResp{}, err