set autocommit=false as default for ZonalFile

Author: suni72

gcsfs/extended_gcsfs.py

@@ -117,7 +117,7 @@ def _open(
         acl=None,
         consistency=None,
         metadata=None,
-        autocommit=True,
+        autocommit=None,
         fixed_key_metadata=None,
         generation=None,
         **kwargs,
@@ -126,7 +126,16 @@ def _open(
         Open a file.
         """
         bucket, _, _ = self.split_path(path)
+
+        # Determine the final autocommit value based on bucket type. For zonal
+        # buckets, default autocommit is False; for others, it is True.
+        final_autocommit = autocommit
         bucket_type = self._sync_lookup_bucket_type(bucket)
+        if autocommit is None:
+            if bucket_type == BucketType.ZONAL_HIERARCHICAL:
+                final_autocommit = False
+            else:
+                final_autocommit = True
         return gcs_file_types[bucket_type](
             self,
             path,
@@ -136,7 +145,7 @@ def _open(
             consistency=consistency,
             metadata=metadata,
             acl=acl,
-            autocommit=autocommit,
+            autocommit=final_autocommit,
             fixed_key_metadata=fixed_key_metadata,
             generation=generation,
             **kwargs,

gcsfs/zonal_file.py

@@ -10,18 +10,29 @@
 
 logger = logging.getLogger("gcsfs.zonal_file")
 
+DEFAULT_BLOCK_SIZE = 5 * 2**20
+
 
 class ZonalFile(GCSFile):
     """
     ZonalFile is subclass of GCSFile and handles data operations from
     Zonal buckets only using a high-performance gRPC path.
     """
 
-    def __init__(self, *args, **kwargs):
+    def __init__(
+        self,
+        gcsfs,
+        path,
+        mode="rb",
+        block_size=DEFAULT_BLOCK_SIZE,
+        autocommit=False,
+        *args,
+        **kwargs,
+    ):
         """
         Initializes the ZonalFile object.
         """
-        super().__init__(*args, **kwargs)
+        super().__init__(gcsfs, path, mode, block_size, autocommit, *args, **kwargs)
         self.mrd = None
         if "r" in self.mode:
             self.mrd = asyn.sync(
@@ -37,7 +48,7 @@ def __init__(self, *args, **kwargs):
             )
         else:
             raise NotImplementedError(
-                "Only read operations are currently supported for Zonal buckets."
+                "Only 'r' and 'w' modes are currently supported for Zonal buckets."
             )
 
     async def _init_mrd(self, bucket_name, object_name, generation=None):