From 378c75658d1b50454ceb8cf4072b09beffb86067 Mon Sep 17 00:00:00 2001
From: roymondchen <roymondchen@tencent.com>
Date: Sun, 27 Apr 2025 17:07:08 +0800
Subject: [PATCH] =?UTF-8?q?fix(data-source):=20=E5=BC=82=E6=AD=A5=E5=8A=A0?=
 =?UTF-8?q?=E8=BD=BD=E6=95=B0=E6=8D=AE=E6=BA=90=E5=90=8E=EF=BC=8C=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E6=BA=90=E6=9C=AA=E5=88=9D=E5=A7=8B=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 packages/data-source/src/DataSourceManager.ts | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/packages/data-source/src/DataSourceManager.ts b/packages/data-source/src/DataSourceManager.ts
index ddccec33..a0f81fea 100644
--- a/packages/data-source/src/DataSourceManager.ts
+++ b/packages/data-source/src/DataSourceManager.ts
@@ -40,7 +40,10 @@ class DataSourceManager extends EventEmitter {
     DataSourceManager.waitInitSchemaList?.forEach((listMap, app) => {
       const list = listMap[type] || [];
       for (let config = list.shift(); config; config = list.shift()) {
-        app.addDataSource(config);
+        const ds = app.addDataSource(config);
+        if (ds) {
+          app.init(ds);
+        }
       }
     });
   }
@@ -140,7 +143,7 @@ class DataSourceManager extends EventEmitter {
     return this.dataSourceMap.get(id);
   }
 
-  public async addDataSource(config?: DataSourceSchema) {
+  public addDataSource(config?: DataSourceSchema) {
     if (!config) return;
 
     const DataSourceClass = DataSourceManager.dataSourceClassMap.get(config.type);
@@ -178,6 +181,8 @@ class DataSourceManager extends EventEmitter {
     ds.on('change', (changeEvent: ChangeEvent) => {
       this.setData(ds, changeEvent);
     });
+
+    return ds;
   }
 
   public setData(ds: DataSource, changeEvent: ChangeEvent) {