Skip to content

Commit 7c85a53

Browse files
committed
Use custom _sleep function
1 parent bb552bc commit 7c85a53

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

elasticsearch/_async/helpers.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -256,9 +256,7 @@ async def map_actions() -> AsyncIterable[_TYPE_BULK_ACTION_HEADER_AND_BODY]:
256256
]
257257
] = []
258258
if attempt:
259-
await anyio.sleep(
260-
min(max_backoff, initial_backoff * 2 ** (attempt - 1))
261-
)
259+
await _sleep(min(max_backoff, initial_backoff * 2 ** (attempt - 1)))
262260

263261
try:
264262
data: Union[

0 commit comments

Comments
 (0)