diff --git a/pipeline_service/rag_client.py b/pipeline_service/rag_client.py
index f79886f..97330b7 100644
--- a/pipeline_service/rag_client.py
+++ b/pipeline_service/rag_client.py
@@ -153,9 +153,10 @@ async def get_owner_apikey(owner_id):
         except Exception as e:
             return "", "dapi 发 key 失败: " + str(e)[:200]
         await sor.sqlExe("COMMIT", {})
-        if not res or res.get("status") != "success" or not res.get("apikey"):
-            return "", "dapi 发 key 失败: " + str(res or {}).get("message", "未知错误")
-        key = res["apikey"]
+        if not isinstance(res, dict) or res.get("status") != "success" or not res.get("apikey"):
+            _msg = res.get("message") if isinstance(res, dict) else str(res)[:120]
+            return "", "dapi 发 key 失败: " + str(_msg or "未知错误")
+        key = res["apikey"] if isinstance(res, dict) else ""
         # RC4 加密存 params（与平台密码字段约定一致）
         pname = _KEY_PARAM_PREFIX + str(owner_id)
         enc = _key_encode(key)