fix: 优化数据源定时同步逻辑

2024-11-26 18:46:20 +08:00 · 2024-11-26 18:46:20 +08:00 · 692228183d
commit 692228183d
parent 93f48678a3
1 changed files with 9 additions and 9 deletions
--- a/core/core-backend/src/main/java/io/dataease/datasource/server/DatasourceServer.java
+++ b/core/core-backend/src/main/java/io/dataease/datasource/server/DatasourceServer.java
@ -989,16 +989,16 @@ public class DatasourceServer implements DatasourceApi {
        datasources.forEach(datasource -> {
            if (!syncDsIds.contains(datasource.getId())) {
                syncDsIds.add(datasource.getId());
+                commonThreadPool.addTask(() -> {
+                    try {
+                        LicenseUtil.validate();
+                        validate(datasource);
+                    } catch (Exception e) {
+                    } finally {
+                        syncDsIds.removeIf(id -> id.equals(datasource.getId()));
+                    }
+                });
            }
-            commonThreadPool.addTask(() -> {
-                try {
-                    LicenseUtil.validate();
-                    validate(datasource);
-                } catch (Exception e) {
-                } finally {
-                    syncDsIds.removeIf(id -> id.equals(datasource.getId()));
-                }
-            });
        });
    }