fix: hive config

2026-11-08 01:06:59 +08:00 · 2026-09-23 10:27:39 +08:00
parent aa41fc1033
commit 2f2326aaa8
1 changed files with 3 additions and 2 deletions
@@ -365,9 +365,10 @@ def check_connection(trans: Optional[Trans], ds: CoreDatasource | AssistantOutDs
                        raise HTTPException(status_code=500, detail=trans('i18n_ds_invalid') + f': {e.args}')
                    return False
        elif equals_ignore_case(ds.type, 'hive'):
+            if conf.password:
+                extra_config_dict['password'] = conf.password
+                extra_config_dict['auth'] = 'LDAP'
            with hive.connect(host=conf.host, port=conf.port, username=conf.username, database=conf.database,
-                              password=conf.password if conf.password else None,
-                              auth='LDAP' if conf.password else None,
                              **extra_config_dict) as conn, conn.cursor() as cursor:
                try:
                    cursor.execute('select 1')