fix: misc

Author: exiaohu

volcenginesdkarkruntime/_exceptions.py

@@ -123,7 +123,7 @@ def __init__(
 
 
 class ArkAPITimeoutError(ArkAPIConnectionError):
-    def __init__(self, request: Optional[httpx.Request] = None, request_id: Optional[str] = None) -> None:
+    def __init__(self, request: httpx.Request, request_id: str) -> None:
         super().__init__(
             message="Request timed out.", request=request, request_id=request_id
         )

volcenginesdkarkruntime/resources/batch_chat/completions.py

@@ -182,7 +182,7 @@ def create(
         while True:
             model_breaker.wait()
             if datetime.now() > last_time:
-                raise ArkAPITimeoutError()
+                raise ArkAPITimeoutError(None, None)
             try:
                 resp = self._post_without_retry(
                     "/batch/chat/completions",
@@ -219,7 +219,7 @@ def create(
             except (ArkAPITimeoutError, ArkAPIConnectionError):
                 waitTime = _calculate_retry_timeout(retryTimes)
                 if datetime.now() + timedelta(seconds=waitTime) > last_time:
-                    raise ArkAPITimeoutError()
+                    raise ArkAPITimeoutError(None, None)
                 time.sleep(waitTime)
                 retryTimes = retryTimes + 1
                 continue
@@ -327,7 +327,7 @@ async def create(
         while True:
             await model_breaker.asyncwait()
             if datetime.now() > last_time:
-                raise ArkAPITimeoutError()
+                raise ArkAPITimeoutError(None, None)
             try:
                 resp = await self._post_without_retry(
                     "/batch/chat/completions",
@@ -364,7 +364,7 @@ async def create(
             except (ArkAPITimeoutError, ArkAPIConnectionError):
                 waitTime = _calculate_retry_timeout(retryTimes)
                 if datetime.now() + timedelta(seconds=waitTime) > last_time:
-                    raise ArkAPITimeoutError()
+                    raise ArkAPITimeoutError(None, None)
                 await asyncio.sleep(waitTime)
                 retryTimes = retryTimes + 1
                 continue