From 25fc1ca36a5a9dc0d328f3c0708be54ec5fce749 Mon Sep 17 00:00:00 2001 From: marvzhang Date: Tue, 7 Jan 2020 13:54:24 +0800 Subject: [PATCH] fixed duplicated AssignTask method --- backend/services/schedule.go | 33 --------------------------------- 1 file changed, 33 deletions(-) diff --git a/backend/services/schedule.go b/backend/services/schedule.go index 769079e5..c321c393 100644 --- a/backend/services/schedule.go +++ b/backend/services/schedule.go @@ -39,11 +39,6 @@ func AddScheduleTask(s model.Schedule) func() { if err := AddTask(t); err != nil { return } - if err := AssignTask(t); err != nil { - log.Errorf(err.Error()) - debug.PrintStack() - return - } } } else if s.RunType == constants.RunTypeRandom { // 随机 @@ -57,11 +52,6 @@ func AddScheduleTask(s model.Schedule) func() { debug.PrintStack() return } - if err := AssignTask(t); err != nil { - log.Errorf(err.Error()) - debug.PrintStack() - return - } } else if s.RunType == constants.RunTypeSelectedNodes { // 指定节点 for _, nodeId := range s.NodeIds { @@ -75,33 +65,10 @@ func AddScheduleTask(s model.Schedule) func() { if err := AddTask(t); err != nil { return } - // AddTask 方法已执行AssignTask - //if err := AssignTask(t); err != nil { - // log.Errorf(err.Error()) - // debug.PrintStack() - // return - //} } } else { return } - - //node, err := model.GetNodeByKey(s.NodeKey) - //if err != nil || node.Id.Hex() == "" { - // log.Errorf("get node by key error: %s", err.Error()) - // debug.PrintStack() - // return - //} - // - //spider := model.GetSpiderByName(s.SpiderName) - //if spider == nil || spider.Id.Hex() == "" { - // log.Errorf("get spider by name error: %s", err.Error()) - // debug.PrintStack() - // return - //} - // - //// 同步ID到定时任务 - //s.SyncNodeIdAndSpiderId(node, *spider) } }