diff --git a/go.mod b/go.mod index b35848795e3..cebb3e07a54 100644 --- a/go.mod +++ b/go.mod @@ -3,7 +3,7 @@ module d7y.io/dragonfly/v2 go 1.21 require ( - d7y.io/api/v2 v2.0.76 + d7y.io/api/v2 v2.0.79 github.com/MysteriousPotato/go-lockable v1.0.0 github.com/RichardKnop/machinery v1.10.6 github.com/Showmax/go-fqdn v1.0.0 diff --git a/go.sum b/go.sum index 1af6cbb9725..99d7dfb0065 100644 --- a/go.sum +++ b/go.sum @@ -51,8 +51,8 @@ cloud.google.com/go/storage v1.6.0/go.mod h1:N7U0C8pVQ/+NIKOBQyamJIeKQKkZ+mxpohl cloud.google.com/go/storage v1.8.0/go.mod h1:Wv1Oy7z6Yz3DshWRJFhqM/UCfaWIRTdp0RXyy7KQOVs= cloud.google.com/go/storage v1.10.0/go.mod h1:FLPqc6j+Ki4BU591ie1oL6qBQGu2Bl/tZ9ullr3+Kg0= cloud.google.com/go/storage v1.14.0/go.mod h1:GrKmX003DSIwi9o29oFT7YDnHYwZoctc3fOKtUw0Xmo= -d7y.io/api/v2 v2.0.76 h1:pDFvUNWSaK/wIkUfF8akxnH8DdtvPxNcrN5kUDBflnQ= -d7y.io/api/v2 v2.0.76/go.mod h1:hiZRuNTy1Tiv7+peJkYloDPm0Sq9GlPTVaiKb2UOhhU= +d7y.io/api/v2 v2.0.79 h1:dKZoqhAOk6/0Lfjh5jMYIzF7tpGrLgd4jwhOBI954J4= +d7y.io/api/v2 v2.0.79/go.mod h1:hiZRuNTy1Tiv7+peJkYloDPm0Sq9GlPTVaiKb2UOhhU= dmitri.shuralyov.com/gpu/mtl v0.0.0-20190408044501-666a987793e9/go.mod h1:H6x//7gZCb22OMCxBHrMx7a5I7Hp++hsVxbQ4BYO7hU= dmitri.shuralyov.com/gpu/mtl v0.0.0-20201218220906-28db891af037/go.mod h1:H6x//7gZCb22OMCxBHrMx7a5I7Hp++hsVxbQ4BYO7hU= github.com/Azure/azure-sdk-for-go v16.2.1+incompatible/go.mod h1:9XXNKU+eRnpl9moKnB4QOLf1HestfXbmab5FXxiDBjc= diff --git a/scheduler/service/service_v2.go b/scheduler/service/service_v2.go index 751115a6717..91c67fa7dd8 100644 --- a/scheduler/service/service_v2.go +++ b/scheduler/service/service_v2.go @@ -848,6 +848,10 @@ func (v *V2) handleRegisterPeerRequest(ctx context.Context, stream schedulerv2.S // If trigger the seed peer download back-to-source, // the need back-to-source flag should be true. download.NeedBackToSource = true + + // Output path should be empty, prevent the seed peer + // copy file to output path. + download.OutputPath = nil if err := v.downloadTaskBySeedPeer(ctx, taskID, download, peer); err != nil { // Collect RegisterPeerFailureCount metrics. metrics.RegisterPeerFailureCount.WithLabelValues(priority.String(), peer.Task.Type.String(),