fix bug

server/node.go

@@ -239,7 +239,7 @@ func (n *Node) Loop(idx int) {
 					failed := make(map[string]bool)
 					for {
 						worker, err := n.poper.PopWorker(ctx, n.rdb, t, failed)
-						if err == ErrNoWorker || err == ErrTimeout {
+						if err == workerpoper.ErrNoWorker || err == workerpoper.ErrTimeout {
 							result := &odysseus.TaskResponse{
 								TaskId:        task.TaskId,
 								TaskUid:       task.TaskUid,

server/worker.go

@@ -16,8 +16,6 @@ import (
 )
 
 var (
-	ErrNoWorker       = errors.New("no worker")
-	ErrTimeout        = errors.New("schedule timeout")
 	ErrDispatchFailed = errors.New("dispatch to nodemanager failed")
 )