Skip to content

Commit

Permalink
feat: 去掉降冷任务判断#2622
Browse files Browse the repository at this point in the history
* feat: 去掉降冷任务判断#2622

* feat: 去掉降冷任务判断#2622
  • Loading branch information
zacYL authored Sep 27, 2024
1 parent 9a30d5a commit 793fa2c
Showing 1 changed file with 0 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,6 @@ import com.tencent.bkrepo.job.batch.utils.MongoShardingUtils
import com.tencent.bkrepo.job.batch.utils.TimeUtils
import com.tencent.bkrepo.job.config.properties.DeletedNodeCleanupJobProperties
import com.tencent.bkrepo.job.migrate.MigrateRepoStorageService
import com.tencent.bkrepo.job.separation.service.SeparationTaskService
import org.slf4j.LoggerFactory
import org.springframework.boot.context.properties.EnableConfigurationProperties
import org.springframework.data.mongodb.core.findOne
Expand All @@ -75,7 +74,6 @@ class DeletedNodeCleanupJob(
private val clusterProperties: ClusterProperties,
private val migrateRepoStorageService: MigrateRepoStorageService,
private val storageCredentialService: StorageCredentialService,
private val separationTaskService: SeparationTaskService,
) : DefaultContextMongoDbJob<DeletedNodeCleanupJob.Node>(properties) {

data class Node(
Expand Down Expand Up @@ -140,11 +138,6 @@ class DeletedNodeCleanupJob(
logger.info("repo[${row.projectId}/${row.repoName}] storage was migrating, skip clean node[${row.sha256}]")
return
}
if (separationTaskService.repoSeparationCheck(row.projectId, row.repoName)) {
logger.info("repo[${row.projectId}/${row.repoName}] was doing separation, skip clean node[${row.sha256}]")
return
}

if (row.folder) {
cleanupFolderNode(context, row.id, collectionName)
} else {
Expand Down

0 comments on commit 793fa2c

Please sign in to comment.