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)