diff --git 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
index d1b4912d6f..7019a45686 100644
--- 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()));
-                }
-            });
         });
     }