Skip to content

Commit dfe261a

Browse files
committed
fix: check ds status
1 parent b203584 commit dfe261a

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

backend/apps/datasource/crud/datasource.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -86,6 +86,7 @@ def create_ds(session: SessionDep, trans: Trans, user: CurrentUser, create_ds: C
8686

8787
def chooseTables(session: SessionDep, id: int, tables: List[CoreTable]):
8888
ds = session.query(CoreDatasource).filter(CoreDatasource.id == id).first()
89+
check_status(session, ds, True)
8990
sync_table(session, ds, tables)
9091
updateNum(session, ds)
9192

@@ -131,6 +132,7 @@ def getTables(session: SessionDep, id: int):
131132

132133

133134
def getTablesByDs(session: SessionDep, ds: CoreDatasource):
135+
check_status(session, ds, True)
134136
tables = get_tables(ds)
135137
return tables
136138

@@ -244,6 +246,7 @@ def preview(session: SessionDep, id: int, data: TableObj):
244246
return {"fields": [], "data": [], "sql": ''}
245247

246248
ds = session.query(CoreDatasource).filter(CoreDatasource.id == id).first()
249+
check_status(session, ds, True)
247250
conf = DatasourceConf(**json.loads(aes_decrypt(ds.configuration))) if ds.type != "excel" else get_engine_config()
248251
sql: str = ""
249252
if ds.type == "mysql":

0 commit comments

Comments
 (0)