Skip to content

Commit 4b9a534

Browse files
committed
Updated implementation of “overwrite_files” mode
1 parent 83d7683 commit 4b9a534

File tree

1 file changed

+6
-3
lines changed

1 file changed

+6
-3
lines changed

awswrangler/s3/_write.py

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,11 @@
3535
}
3636

3737

38-
def _compose_filename_prefix_for_mode(*, mode: str, filename_prefix: str = None) -> tuple[str, str]:
38+
def _load_mode_and_filename_prefix(
39+
*, mode: str | None, filename_prefix: str | None = None) -> tuple[str, str]:
40+
if mode is None:
41+
mode = "append"
42+
3943
if mode == "overwrite_files":
4044
if filename_prefix is None:
4145
filename_prefix = "part"
@@ -299,8 +303,7 @@ def write( # noqa: PLR0913
299303
dtype = dtype if dtype else {}
300304
partitions_values: dict[str, list[str]] = {}
301305

302-
mode, filename_prefix = _compose_filename_prefix_for_mode(mode=mode, filename_prefix=filename_prefix)
303-
mode = "append" if mode is None else mode
306+
mode, filename_prefix = _load_mode_and_filename_prefix(mode=mode, filename_prefix=filename_prefix)
304307
cpus: int = _utils.ensure_cpu_count(use_threads=use_threads)
305308
s3_client = _utils.client(service_name="s3", session=boto3_session)
306309

0 commit comments

Comments
 (0)