Revert "set autocommit=false as default for ZonalFile"

This reverts commit d51c8c3.

Author: suni72

gcsfs/extended_gcsfs.py

@@ -122,7 +122,7 @@ def _open(
         acl=None,
         consistency=None,
         metadata=None,
-        autocommit=None,
+        autocommit=True,
         fixed_key_metadata=None,
         generation=None,
         **kwargs,
@@ -131,16 +131,7 @@ 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,
@@ -150,7 +141,7 @@ def _open(
             consistency=consistency,
             metadata=metadata,
             acl=acl,
-            autocommit=final_autocommit,
+            autocommit=autocommit,
             fixed_key_metadata=fixed_key_metadata,
             generation=generation,
             **kwargs,

gcsfs/zonal_file.py

@@ -10,29 +10,18 @@
 
 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,
-        gcsfs,
-        path,
-        mode="rb",
-        block_size=DEFAULT_BLOCK_SIZE,
-        autocommit=False,
-        *args,
-        **kwargs,
-    ):
+    def __init__(self, *args, **kwargs):
         """
         Initializes the ZonalFile object.
         """
-        super().__init__(gcsfs, path, mode, block_size, autocommit, *args, **kwargs)
+        super().__init__(*args, **kwargs)
         self.mrd = None
         if "r" in self.mode:
             self.mrd = asyn.sync(
@@ -48,7 +37,7 @@ def __init__(
             )
         else:
             raise NotImplementedError(
-                "Only 'r' and 'w' modes are currently supported for Zonal buckets."
+                "Only read operations are currently supported for Zonal buckets."
             )
 
     async def _init_mrd(self, bucket_name, object_name, generation=None):