Skip to content

Commit 3cd2325

Browse files
committed
fix(binaries): don't synchronously block in astream_to_file (#167)
1 parent 89ac82e commit 3cd2325

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

src/finch/_base_client.py

+3-2
Original file line numberDiff line numberDiff line change
@@ -1758,9 +1758,10 @@ async def aiter_raw(self, chunk_size: Optional[int] = None) -> AsyncIterator[byt
17581758

17591759
@override
17601760
async def astream_to_file(self, file: str | os.PathLike[str]) -> None:
1761-
with open(file, mode="wb") as f:
1761+
path = anyio.Path(file)
1762+
async with await path.open(mode="wb") as f:
17621763
async for data in self.response.aiter_bytes():
1763-
f.write(data)
1764+
await f.write(data)
17641765

17651766
@override
17661767
async def aclose(self) -> None:

0 commit comments

Comments
 (0)