diff --git a/client/daemon/peer/piece_dispatcher_test.go b/client/daemon/peer/piece_dispatcher_test.go
deleted file mode 100644
index b38ebc37c85..00000000000
--- a/client/daemon/peer/piece_dispatcher_test.go
+++ /dev/null
@@ -1,169 +0,0 @@
-/*
- *     Copyright 2022 The Dragonfly Authors
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package peer
-
-import (
-	"cmp"
-	"math/rand"
-	"sync"
-	"testing"
-	"time"
-
-	"golang.org/x/exp/maps"
-	"golang.org/x/exp/slices"
-
-	commonv1 "d7y.io/api/v2/pkg/apis/common/v1"
-
-	logger "d7y.io/dragonfly/v2/internal/dflog"
-)
-
-type peerDesc struct {
-	id         string
-	uploadTime time.Duration
-	count      *int
-}
-
-type pieceTestManager struct {
-	pieceDispatcher PieceDispatcher
-	peers           map[string]peerDesc
-	pieceNum        int
-}
-
-func newPieceTestManager(pieceDispatcher PieceDispatcher, peers []peerDesc, pieceNum int) *pieceTestManager {
-	peerMap := make(map[string]peerDesc)
-	for _, p := range peers {
-		peerMap[p.id] = peerDesc{
-			id:         p.id,
-			uploadTime: p.uploadTime,
-			count:      new(int),
-		}
-	}
-	pm := &pieceTestManager{
-		pieceDispatcher: pieceDispatcher,
-		peers:           peerMap,
-		pieceNum:        pieceNum,
-	}
-	return pm
-}
-
-func (pc *pieceTestManager) Run() {
-	wg := &sync.WaitGroup{}
-	wg.Add(1)
-	// producer
-	go func() {
-		slice := make([]*DownloadPieceRequest, 0)
-		for range 4 {
-			for _, peer := range pc.peers {
-				for j := range pc.pieceNum {
-					slice = append(slice, &DownloadPieceRequest{
-						piece:  &commonv1.PieceInfo{PieceNum: int32(j)},
-						DstPid: peer.id,
-					})
-				}
-			}
-		}
-		rand.Shuffle(len(slice), func(i, j int) {
-			tmp := slice[i]
-			slice[i] = slice[j]
-			slice[j] = tmp
-		})
-		for _, req := range slice {
-			pc.pieceDispatcher.Put(req)
-		}
-		wg.Done()
-	}()
-
-	// consumer
-	wg.Add(1)
-	go func() {
-		downloaded := map[int32]struct{}{}
-		for {
-			req, err := pc.pieceDispatcher.Get()
-			if err == ErrNoValidPieceTemporarily {
-				continue
-			}
-			if err != nil {
-				break
-			}
-			*pc.peers[req.DstPid].count = *pc.peers[req.DstPid].count + 1
-			downloaded[req.piece.PieceNum] = struct{}{}
-			pc.pieceDispatcher.Report(&DownloadPieceResult{
-				pieceInfo:  req.piece,
-				DstPeerID:  req.DstPid,
-				BeginTime:  time.Now().UnixNano(),
-				FinishTime: time.Now().Add(pc.peers[req.DstPid].uploadTime).UnixNano(),
-			})
-			if len(downloaded) >= pc.pieceNum {
-				break
-			}
-		}
-		pc.pieceDispatcher.Close()
-		wg.Done()
-	}()
-	wg.Wait()
-}
-
-// return a slice of peerIDs, order by count desc
-func (pc *pieceTestManager) Order() []string {
-	peerIDs := maps.Keys(pc.peers)
-	slices.SortFunc(peerIDs, func(a, b string) int { return cmp.Compare(*pc.peers[a].count, *pc.peers[b].count) })
-	return peerIDs
-}
-
-func TestPieceDispatcherCount(t *testing.T) {
-	type args struct {
-		randomRatio float64
-		peers       []peerDesc
-		pieceNum    int
-	}
-	tests := []struct {
-		name string
-		args args
-		want map[string]int
-	}{
-		{
-			name: "no random",
-			args: args{
-				randomRatio: 0,
-				peers: []peerDesc{
-					{"bad", time.Second * 4, nil},
-					{"mid", time.Second * 3, nil},
-					{"good", time.Second * 2, nil},
-				},
-				pieceNum: 10000,
-			},
-			want: map[string]int{
-				"bad":  0,
-				"mid":  0,
-				"good": 4000,
-			},
-		},
-	}
-	for _, tt := range tests {
-		t.Run(tt.name, func(t *testing.T) {
-			pieceDispatcher := NewPieceDispatcher(tt.args.randomRatio, logger.With())
-			pieceTestManager := newPieceTestManager(pieceDispatcher, tt.args.peers, tt.args.pieceNum)
-			pieceTestManager.Run()
-			for p, c := range tt.want {
-				if *pieceTestManager.peers[p].count < c {
-					t.Errorf("peer %s should receive more pieces than %d, however get %d", p, c, *pieceTestManager.peers[p].count)
-					t.Fail()
-				}
-			}
-		})
-	}
-}
diff --git a/codecov.yml b/codecov.yml
index 00ec9eaad7b..ed609900b0d 100644
--- a/codecov.yml
+++ b/codecov.yml
@@ -6,7 +6,7 @@ coverage:
     project:
       default:
         enabled: yes
-        target: 34%
+        target: 33%
     patch:
       default:
         enabled: no
diff --git a/manager/router/router.go b/manager/router/router.go
index cd918851b7c..a2603fb4c8d 100644
--- a/manager/router/router.go
+++ b/manager/router/router.go
@@ -252,7 +252,7 @@ func Init(cfg *config.Config, logDir string, service service.Service, database *
 
 	// Job.
 	ojob := oapiv1.Group("/jobs", personalAccessToken)
-	ojob.POST("", h.CreateJob)
+	ojob.POST("", middlewares.CreateJobRateLimiter(limiter), h.CreateJob)
 	ojob.DELETE(":id", h.DestroyJob)
 	ojob.PATCH(":id", h.UpdateJob)
 	ojob.GET(":id", h.GetJob)