Remove overwrite parameter since it is not added in AAOW. instead use generation=None to overwrite

Author: suni72

gcsfs/zonal_file.py

@@ -28,7 +28,7 @@ def __init__(self, *args, **kwargs):
             )
         elif "w" in self.mode:
             self.aaow = asyn.sync(
-                self.gcsfs.loop, self._init_aaow, self.bucket, self.key, self.generation
+                self.gcsfs.loop, self._init_aaow, self.bucket, self.key
             )
         else:
             raise NotImplementedError(
@@ -56,17 +56,14 @@ def _fetch_range(self, start, end):
             raise
 
     async def _init_aaow(
-        self, bucket_name, object_name, generation=None, overwrite=True
+        self, bucket_name, object_name, generation=None
     ):
         """
         Initializes the AsyncAppendableObjectWriter.
         """
-        if generation is None and await self.gcsfs._exists(self.path):
-            info = self.gcsfs.info(self.path)
-            generation = info.get("generation")
 
         return await zb_hns_utils.init_aaow(
-            self.gcsfs.grpc_client, bucket_name, object_name, generation, overwrite
+            self.gcsfs.grpc_client, bucket_name, object_name, generation
         )
 
     def write(self, data):

requirements.txt

@@ -3,6 +3,6 @@ decorator>4.1.2
 fsspec==2025.10.0
 google-auth>=1.2
 google-auth-oauthlib
-google-cloud-storage
+git+https://github.com/googleapis/python-storage.git@bidi-writes-6#egg=google-cloud-storage
 google-cloud-storage-control
 requests