git-sync/crawlab
1
0
Fork 0
mirror of https://github.com/crawlab-team/crawlab.git synced 2026-01-21 17:21:09 +01:00
Code Issues Packages Projects Releases Wiki Activity

feat: optimized dependency logic

Browse Source
This commit is contained in:
Marvin Zhang
2024-11-05 18:42:33 +08:00
parent 0f34a546b8
commit bd5062bc70
1 changed files with 0 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
core/grpc/server/dependency_service_server.go
View File

@@ -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)