From ce8fb90c7825b0dfcf278d412d01e114ca833648 Mon Sep 17 00:00:00 2001 From: kanlon Date: Wed, 1 Jan 2025 15:38:11 +0800 Subject: [PATCH] refactor: source status is archived not need sync schema --- server/src/main/java/datart/server/job/SchemaSyncJob.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/server/src/main/java/datart/server/job/SchemaSyncJob.java b/server/src/main/java/datart/server/job/SchemaSyncJob.java index 93bcf6fde..4c78f466b 100644 --- a/server/src/main/java/datart/server/job/SchemaSyncJob.java +++ b/server/src/main/java/datart/server/job/SchemaSyncJob.java @@ -19,6 +19,7 @@ package datart.server.job; import com.fasterxml.jackson.databind.ObjectMapper; +import datart.core.base.consts.Const; import datart.core.common.Application; import datart.core.common.TransactionHelper; import datart.core.common.UUIDGenerator; @@ -41,6 +42,7 @@ import java.util.LinkedList; import java.util.List; import java.util.Set; +import java.util.Objects; @Slf4j public class SchemaSyncJob implements Job, Closeable { @@ -62,8 +64,8 @@ public void execute(JobExecutionContext context) throws JobExecutionException { source = Application.getBean(SourceService.class).retrieve(sourceId, false); } catch (Exception ignored) { } - // remove job if source not exists - if (source == null) { + // remove job if source not exists or status is archived + if (source == null || Objects.equals(Const.DATA_STATUS_ARCHIVED, source.getStatus())) { JobKey key = context.getJobDetail().getKey(); Application.getBean(Scheduler.class).deleteJob(key); log.warn("source {} not exists , the job has been deleted ", sourceId);