feat：同一流水线多次构建时资源调度优先级优化 TencentBlueKing#9897

tangruotian · Aug 23, 2024 · dd4efaf · dd4efaf
1 parent 273aebb
commit dd4efaf
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/...-dispatch/src/main/kotlin/com/tencent/devops/dispatch/service/tpaqueue/TPAQueueService.kt b/...-dispatch/src/main/kotlin/com/tencent/devops/dispatch/service/tpaqueue/TPAQueueService.kt
@@ -4,7 +4,6 @@ import com.tencent.devops.common.api.constant.CommonMessageCode.BK_FAILED_START_
 import com.tencent.devops.common.api.exception.InvalidParamException
 import com.tencent.devops.common.api.pojo.ErrorType
 import com.tencent.devops.common.api.util.timestampmilli
-import com.tencent.devops.common.client.Client
 import com.tencent.devops.common.dispatch.sdk.BuildFailureException
 import com.tencent.devops.common.dispatch.sdk.DispatchSdkErrorCode
 import com.tencent.devops.common.dispatch.sdk.service.DispatchService
@@ -37,7 +36,6 @@ class TPAQueueService @Autowired constructor(
     private val dslContext: DSLContext,
     private val redisOperation: RedisOperation,
     private val rabbitTemplate: RabbitTemplate,
-    private val client: Client,
     private val commonUtil: TPACommonUtil,
     private val tpaQueueDao: TPAQueueDao,
     private val tpaEnvQueueService: TPAEnvQueueService,
@@ -308,7 +306,8 @@ class TPAQueueService @Autowired constructor(
             pipelineId = data.pipelineId,
             buildId = data.buildId,
             vmSeqId = data.vmSeqId,
-            e = exception
+            e = exception,
+            logTag = data.toLog()
         )
     }