From 62063c6b209808d4dae479cde72254ba8645429c Mon Sep 17 00:00:00 2001 From: Alex Ford <282792+asford@users.noreply.github.com> Date: Wed, 5 Mar 2025 12:50:56 -0800 Subject: [PATCH] Add **kwargs to cat_file, mirroring pipe_file. Extend cat_file interface with kwargs to match pipe_file, allowing conditional `IfMatch` passed into s3 requests. --- s3fs/core.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/s3fs/core.py b/s3fs/core.py index cf32e702..e2d28a6d 100644 --- a/s3fs/core.py +++ b/s3fs/core.py @@ -1136,7 +1136,7 @@ async def _touch(self, path, truncate=True, data=None, **kwargs): touch = sync_wrapper(_touch) - async def _cat_file(self, path, version_id=None, start=None, end=None): + async def _cat_file(self, path, version_id=None, start=None, end=None, **kwargs): bucket, key, vers = self.split_path(path) if start is not None or end is not None: head = {"Range": await self._process_limits(path, start, end)} @@ -1151,6 +1151,7 @@ async def _call_and_read(): **version_id_kw(version_id or vers), **head, **self.req_kw, + **kwargs, ) try: return await resp["Body"].read()