Skip to content

Commit 08dc8ed

Browse files
committed
"" -> ""ReadError after 5 retries over 312s""
1 parent 971a150 commit 08dc8ed

2 files changed

Lines changed: 11 additions & 3 deletions

File tree

src/unstructured_client/_version.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
import importlib.metadata
44

55
__title__: str = "unstructured-client"
6-
__version__: str = "0.43.2"
6+
__version__: str = "0.43.3"
77
__openapi_doc_version__: str = "1.2.31"
88
__gen_version__: str = "2.680.0"
99
__user_agent__: str = "speakeasy-sdk/python 0.43.2 2.680.0 1.2.31 unstructured-client"

src/unstructured_client/utils/retries.py

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -172,7 +172,11 @@ def retry_with_backoff(
172172
if isinstance(exception, TemporaryError):
173173
return exception.response
174174

175-
raise
175+
elapsed_seconds = (now - start) / 1000
176+
raise type(exception)(
177+
f"{type(exception).__name__} after {retries + 1} retries "
178+
f"over {elapsed_seconds:.1f}s: {exception}"
179+
) from exception
176180
sleep = (initial_interval / 1000) * exponent**retries + random.uniform(0, 1)
177181
sleep = min(sleep, max_interval / 1000)
178182
time.sleep(sleep)
@@ -200,7 +204,11 @@ async def retry_with_backoff_async(
200204
if isinstance(exception, TemporaryError):
201205
return exception.response
202206

203-
raise
207+
elapsed_seconds = (now - start) / 1000
208+
raise type(exception)(
209+
f"{type(exception).__name__} after {retries + 1} retries "
210+
f"over {elapsed_seconds:.1f}s: {exception}"
211+
) from exception
204212
sleep = (initial_interval / 1000) * exponent**retries + random.uniform(0, 1)
205213
sleep = min(sleep, max_interval / 1000)
206214
await asyncio.sleep(sleep)

0 commit comments

Comments
 (0)