fix: 修复扫描执行服务拉取镜像失败 #2766

* fix: 修复扫描执行服务拉取镜像失败 #2766 * fix: 修复扫描执行服务拉取镜像失败 #2766 * fix: 调整制品分析日志级别 #2766
TencentBlueKing · Nov 21, 2024 · ee1d45b · ee1d45b
1 parent 01210ad
commit ee1d45b
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/...nalyst/biz-analyst/src/main/kotlin/com/tencent/bkrepo/analyst/dispatcher/SubtaskPoller.kt b/...nalyst/biz-analyst/src/main/kotlin/com/tencent/bkrepo/analyst/dispatcher/SubtaskPoller.kt
@@ -69,9 +69,9 @@ open class SubtaskPoller(
     open fun dispatch() {
         executionClusterService.list().forEach {
             executor.execute {
-                logger.info("cluster [${it.name}] start to dispatch subtask")
+                logger.debug("cluster [${it.name}] start to dispatch subtask")
                 dispatcherCache.get(it.name).dispatch()
-                logger.info("cluster [${it.name}] dispatch finished")
+                logger.debug("cluster [${it.name}] dispatch finished")
             }
         }
     }

diff --git a/...iz-analyst/src/main/kotlin/com/tencent/bkrepo/analyst/dispatcher/SubtaskPushDispatcher.kt b/...iz-analyst/src/main/kotlin/com/tencent/bkrepo/analyst/dispatcher/SubtaskPushDispatcher.kt
@@ -36,7 +36,7 @@ abstract class SubtaskPushDispatcher<T : ExecutionCluster>(
 
     override fun dispatch() {
         if (scanService.peek(executionCluster.name) == null) {
-            logger.info("cluster [${executionCluster.name}] has no subtask to dispatch")
+            logger.debug("cluster [${executionCluster.name}] has no subtask to dispatch")
             return
         }
 

diff --git a/...ysis/src/main/kotlin/com/tencent/bkrepo/common/analysis/pojo/scanner/utils/DockerUtils.kt b/...ysis/src/main/kotlin/com/tencent/bkrepo/common/analysis/pojo/scanner/utils/DockerUtils.kt
@@ -65,9 +65,9 @@ object DockerUtils {
         password: String?,
     ) {
         val images = listImagesCmd().exec()
-        val exists = images.any { image ->
-            image.repoTags.any { it == tag }
-        }
+        val exists = images?.any { image ->
+            image.repoTags?.any { it == tag } ?: false
+        } ?: false
         if (exists) {
             return
         }