fix async ptaas

Change-Id: If57b470952a1db94d67dc36430262f2ee720d209

Author: kasarolzzw

cozeloop/internal/httpclient/client.py

@@ -153,6 +153,47 @@ def post_stream(
             logger.error(f"Http client stream request failed, path: {path}, err: {e}.")
             raise consts.NetworkError from e
 
+    async def arequest(
+            self,
+            path: str,
+            method: str,
+            response_model: Type[T],
+            *,
+            params: Optional[Dict[str, str]] = None,
+            form: Optional[Dict[str, str]] = None,
+            json: Optional[Union[BaseModel, Dict]] = None,
+            files: Optional[Dict[str, FileType]] = None,
+            headers: Optional[Dict[str, str]] = None,
+            timeout: Optional[int] = None,
+    ) -> T:
+        url = self._build_url(path)
+        _headers = self._set_headers(headers)
+
+        _timeout = timeout if timeout is not None else self.timeout
+
+        if isinstance(json, BaseModel):
+            if pydantic.VERSION.startswith('1'):
+                json = json.dict(by_alias=True)
+            else:
+                json = json.model_dump(by_alias=True)
+
+        try:
+            response = await self.http_client.arequest(
+                method,
+                url,
+                params=params,
+                data=form,
+                json=json,
+                files=files,
+                headers=_headers,
+                timeout=_timeout
+            )
+        except httpx.HTTPError as e:
+            logger.error(f"Http client request failed, path: {path}, err: {e}.")
+            raise consts.NetworkError from e
+
+        return parse_response(url, response, response_model)
+
     async def apost_stream(
             self,
             path: str,
@@ -170,7 +211,7 @@ async def apost_stream(
 
         try:
             # 返回stream_context，让StreamReader管理上下文
-            stream_context = self.http_client.stream(
+            stream_context = self.http_client.astream(
                 "POST",
                 url,
                 json=json,

cozeloop/internal/prompt/openapi.py

@@ -259,7 +259,7 @@ def execute_streaming(self, request: ExecuteRequest, timeout: Optional[int] = No
 
     async def aexecute(self, request: ExecuteRequest, timeout: Optional[int] = None) -> ExecuteData:
         """异步执行Prompt请求"""
-        response = self.http_client.request(
+        response = await self.http_client.arequest(
             EXECUTE_PROMPT_PATH, 
             "POST", 
             ExecuteResponse,