Skip to content

Commit 2327ace

Browse files
committed
More consistent "sync" vs "blocking"
1 parent 6179c4b commit 2327ace

File tree

3 files changed

+10
-11
lines changed

3 files changed

+10
-11
lines changed

src/vercel/blob/_core.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,7 @@
7171
)
7272

7373

74-
def _blocking_sleep(seconds: float) -> None:
74+
def _sync_sleep(seconds: float) -> None:
7575
time.sleep(seconds)
7676

7777

@@ -763,15 +763,15 @@ def __init__(self, *, timeout: float = 30.0) -> None:
763763
call_complete_multipart_upload,
764764
call_create_multipart_upload,
765765
)
766-
from .multipart.uploader import create_blocking_multipart_upload_runtime
766+
from .multipart.uploader import create_sync_multipart_upload_runtime
767767

768768
transport = BlockingTransport(create_base_client(timeout=timeout))
769769
super().__init__(
770770
transport=transport,
771-
sleep_fn=_blocking_sleep,
771+
sleep_fn=_sync_sleep,
772772
await_progress_callback=False,
773773
async_content=False,
774-
multipart_runtime=create_blocking_multipart_upload_runtime(),
774+
multipart_runtime=create_sync_multipart_upload_runtime(),
775775
create_multipart_upload=call_create_multipart_upload,
776776
complete_multipart_upload=call_complete_multipart_upload,
777777
)

src/vercel/blob/api.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010
from .utils import PutHeaders, UploadProgressEvent
1111

1212

13-
def _blocking_sleep(seconds: float) -> None:
13+
def _sync_sleep(seconds: float) -> None:
1414
time.sleep(seconds)
1515

1616

@@ -40,7 +40,7 @@ def request_api(
4040
on_upload_progress=on_upload_progress,
4141
timeout=timeout,
4242
transport=transport,
43-
sleep_fn=_blocking_sleep,
43+
sleep_fn=_sync_sleep,
4444
await_progress_callback=False,
4545
async_content=False,
4646
)

src/vercel/blob/multipart/uploader.py

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -171,7 +171,7 @@ async def _aiter_part_bytes(body: Any, part_size: int) -> AsyncIterator[bytes]:
171171
yield chunk
172172

173173

174-
class _BlockingMultipartUploadRuntime:
174+
class _SyncMultipartUploadRuntime:
175175
def upload(
176176
self,
177177
*,
@@ -300,9 +300,8 @@ async def upload_one(part_number: int, content: bytes) -> dict[str, Any]:
300300
return results
301301

302302

303-
def create_blocking_multipart_upload_runtime() -> _BlockingMultipartUploadRuntime:
304-
return _BlockingMultipartUploadRuntime()
305-
303+
def create_sync_multipart_upload_runtime() -> _SyncMultipartUploadRuntime:
304+
return _SyncMultipartUploadRuntime()
306305

307306
def create_async_multipart_upload_runtime() -> _AsyncMultipartUploadRuntime:
308307
return _AsyncMultipartUploadRuntime()
@@ -339,7 +338,7 @@ def auto_multipart_upload(
339338
token=token,
340339
)
341340

342-
runtime = create_blocking_multipart_upload_runtime()
341+
runtime = create_sync_multipart_upload_runtime()
343342
total = compute_body_length(body)
344343
parts = runtime.upload(
345344
session=session,

0 commit comments

Comments
 (0)