From bd5062bc7085cd441e2fea5107708ee5d573b585 Mon Sep 17 00:00:00 2001 From: Marvin Zhang Date: Tue, 5 Nov 2024 18:42:33 +0800 Subject: [PATCH] feat: optimized dependency logic --- core/grpc/server/dependency_service_server.go | 10 ---------- 1 file changed, 10 deletions(-) diff --git a/core/grpc/server/dependency_service_server.go b/core/grpc/server/dependency_service_server.go index 792d7d21..d107ebf7 100644 --- a/core/grpc/server/dependency_service_server.go +++ b/core/grpc/server/dependency_service_server.go @@ -143,7 +143,6 @@ func (svr DependencyServiceServer) Sync(_ context.Context, request *grpc.Depende } func (svr DependencyServiceServer) UpdateLogs(stream grpc.DependencyService_UpdateLogsServer) (err error) { - var n *models.Node var dep *models.Dependency for { // receive message @@ -156,15 +155,6 @@ func (svr DependencyServiceServer) UpdateLogs(stream grpc.DependencyService_Upda return err } - // if node is nil, get node - if n == nil { - n, err = service.NewModelService[models.Node]().GetOne(bson.M{"key": req.NodeKey}, nil) - if err != nil { - log.Errorf("[DependencyServiceServer] get node error: %v", err) - return err - } - } - // if dependency is nil, get dependency if dep == nil { id, err := primitive.ObjectIDFromHex(req.DependencyId)