feat: worker选取及恢复机制优化 TencentBlueKing#311

tbs60 · Nov 22, 2024 · 7f70df0 · 7f70df0
1 parent 4642326
commit 7f70df0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/backend/booster/bk_dist/controller/pkg/manager/remote/mgr.go b/src/backend/booster/bk_dist/controller/pkg/manager/remote/mgr.go
@@ -635,7 +635,7 @@ func (m *Mgr) retrySendToolChains(ctx context.Context) {
 			blog.Infof("remote: run toolchain check for work(%s) canceled by context", m.work.ID())
 			return
 		case <-ticker.C:
-			if m.failFileSendMap == nil {
+			if m.failFileSendMap == nil || len(m.failFileSendMap) == 0 {
 				continue
 			}
 			handler := m.remoteWorker.Handler(0, nil, nil, nil)
@@ -684,7 +684,7 @@ func (m *Mgr) retryFailFiles(ctx context.Context) {
 			blog.Infof("remote: run failfiles check for work(%s) canceled by context", m.work.ID())
 			return
 		case <-ticker.C:
-			if m.failFileSendMap == nil {
+			if m.failFileSendMap == nil || len(m.failFileSendMap) == 0 {
 				continue
 			}
 			hosts := m.work.Resource().GetHosts()