Merge pull request TencentBlueKing#185 from tbs60/dev_tming_p2p

Dev tming p2p
tbs60 · Mar 26, 2024 · 751decf · 751decf
2 parents 3d5009c + c083f36
commit 751decf
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/backend/booster/server/pkg/engine/disttask/engine.go b/src/backend/booster/server/pkg/engine/disttask/engine.go
@@ -681,6 +681,8 @@ func (de *disttaskEngine) launchCRMTask(task *distTask, tb *engine.TaskBasic, qu
 	}
 	var err error
 
+	de.setTaskIstResource(task, queueName)
+
 	envJobInt := int(task.Operator.RequestCPUPerUnit)
 	if task.Operator.RequestProcessPerUnit > 0 {
 		envJobInt = task.Operator.RequestProcessPerUnit
@@ -721,7 +723,7 @@ func (de *disttaskEngine) launchCRMTask(task *distTask, tb *engine.TaskBasic, qu
 		return err
 	}
 
-	de.setTaskIstResource(task, queueName)
+	// de.setTaskIstResource(task, queueName)
 
 	err = crmMgr.Launch(tb.ID, pureQueueName, func(availableInstance int) (int, error) {
 		if availableInstance < task.Operator.LeastInstance {