From cede829140cbfe0b812c647df5ffbc6d893c4a15 Mon Sep 17 00:00:00 2001 From: Gaius Date: Thu, 13 Jul 2023 15:37:04 +0800 Subject: [PATCH] feat: update api verison to v1.9.7 and compatible with tiny task response (#2547) Signed-off-by: Gaius --- go.mod | 2 +- go.sum | 4 ++-- scheduler/service/service_v2.go | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/go.mod b/go.mod index 78d627c3e..9cea75e2e 100644 --- a/go.mod +++ b/go.mod @@ -3,7 +3,7 @@ module d7y.io/dragonfly/v2 go 1.20 require ( - d7y.io/api v1.9.6 + d7y.io/api v1.9.7 github.com/MysteriousPotato/go-lockable v0.2.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 1d2743a08..b6a73ddc1 100644 --- a/go.sum +++ b/go.sum @@ -50,8 +50,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 v1.9.6 h1:AjFCSlXDCYZXwxFr/HSu5c/2lK4C/UQpyNbFWcf9aWc= -d7y.io/api v1.9.6/go.mod h1:cvI0E7xUfVbl1FhdIi4vUPzbYl9sG9u7pUZykqKOGTc= +d7y.io/api v1.9.7 h1:bHgCpAIP99dbMxn7Nv/1FRWiJXpeZXVMfaUDYKIhwFY= +d7y.io/api v1.9.7/go.mod h1:cvI0E7xUfVbl1FhdIi4vUPzbYl9sG9u7pUZykqKOGTc= 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/sdk/azcore v1.0.0/go.mod h1:uGG2W01BaETf0Ozp+QxxKJdMBNRWPdstHG0Fmdwn1/U= diff --git a/scheduler/service/service_v2.go b/scheduler/service/service_v2.go index 27f000e32..6433ea079 100644 --- a/scheduler/service/service_v2.go +++ b/scheduler/service/service_v2.go @@ -1393,7 +1393,7 @@ func (v *V2) schedule(ctx context.Context, peer *resource.Peer) error { if err := stream.Send(&schedulerv2.AnnouncePeerResponse{ Response: &schedulerv2.AnnouncePeerResponse_TinyTaskResponse{ TinyTaskResponse: &schedulerv2.TinyTaskResponse{ - Data: peer.Task.DirectPiece, + Content: peer.Task.DirectPiece, }, }, }); err != nil {