diff --git a/etl-modules/etl-modules-data-source/etl-modules-data-source-system/src/main/java/com/etl/data/source/service/impl/DataSourceServiceImpl.java b/etl-modules/etl-modules-data-source/etl-modules-data-source-system/src/main/java/com/etl/data/source/service/impl/DataSourceServiceImpl.java
index b828ed5..9dd198a 100644
--- a/etl-modules/etl-modules-data-source/etl-modules-data-source-system/src/main/java/com/etl/data/source/service/impl/DataSourceServiceImpl.java
+++ b/etl-modules/etl-modules-data-source/etl-modules-data-source-system/src/main/java/com/etl/data/source/service/impl/DataSourceServiceImpl.java
@@ -1,6 +1,7 @@
 package com.etl.data.source.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.etl.common.core.utils.DateUtils;
 import com.etl.data.source.domain.DataSource;
@@ -181,6 +182,19 @@ public class DataSourceServiceImpl extends ServiceImpl<DataSourceMapper, DataSou
                     flag = false;
                 }
             }
+            if (flag) {
+                this.update(
+                        new UpdateWrapper<DataSource>()
+                                .set("status", "S")
+                                .eq("id", id)
+                );
+            } else {
+                this.update(
+                        new UpdateWrapper<DataSource>()
+                                .set("status", "E")
+                                .eq("id", id)
+                );
+            }
             return flag;
         } catch (Exception e) {
             return flag;