Skip to content

Commit 8427749

Browse files
committed
Remove redundant init_aaow method from zonal_file
1 parent c104f3d commit 8427749

File tree

3 files changed

+11
-13
lines changed

3 files changed

+11
-13
lines changed

gcsfs/zb_hns_utils.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,9 @@
11
from io import BytesIO
22

3+
from google.cloud.storage._experimental.asyncio.async_appendable_object_writer import (
4+
AsyncAppendableObjectWriter,
5+
)
6+
37

48
async def download_range(offset, length, mrd):
59
"""

gcsfs/zonal_file.py

Lines changed: 6 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@
55
AsyncMultiRangeDownloader,
66
)
77

8+
from gcsfs import zb_hns_utils
89
from gcsfs.core import GCSFile
910

1011
logger = logging.getLogger("gcsfs.zonal_file")
@@ -28,7 +29,11 @@ def __init__(self, *args, **kwargs):
2829
)
2930
elif "w" in self.mode:
3031
self.aaow = asyn.sync(
31-
self.gcsfs.loop, self._init_aaow, self.bucket, self.key
32+
self.gcsfs.loop,
33+
zb_hns_utils.init_aaow,
34+
self.gcsfs.grpc_client,
35+
self.bucket,
36+
self.key,
3237
)
3338
else:
3439
raise NotImplementedError(
@@ -55,17 +60,6 @@ def _fetch_range(self, start, end):
5560
return b""
5661
raise
5762

58-
async def _init_aaow(
59-
self, bucket_name, object_name, generation=None
60-
):
61-
"""
62-
Initializes the AsyncAppendableObjectWriter.
63-
"""
64-
65-
return await zb_hns_utils.init_aaow(
66-
self.gcsfs.grpc_client, bucket_name, object_name, generation
67-
)
68-
6963
def write(self, data):
7064
"""
7165
Writes data using AsyncAppendableObjectWriter.

requirements.txt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,6 @@ decorator>4.1.2
33
fsspec==2025.10.0
44
google-auth>=1.2
55
google-auth-oauthlib
6-
git+https://github.com/googleapis/python-storage.git@bidi-writes-6#egg=google-cloud-storage
6+
google-cloud-storage
77
google-cloud-storage-control
88
requests

0 commit comments

Comments
 (0)