diff --git a/dvc/remote/s3.py b/dvc/remote/s3.py index ba043afcdd..bcc1cffb83 100644 --- a/dvc/remote/s3.py +++ b/dvc/remote/s3.py @@ -3,6 +3,7 @@ import logging import os import threading +from boto3.s3.transfer import TransferConfig from funcy import cached_property, wrap_prop @@ -169,7 +170,13 @@ def _copy(cls, s3, from_info, to_info, extra_args): ) else: source = {"Bucket": from_info.bucket, "Key": from_info.path} - s3.copy(source, to_info.bucket, to_info.path, ExtraArgs=extra_args) + s3.copy( + source, + to_info.bucket, + to_info.path, + ExtraArgs=extra_args, + Config=TransferConfig(multipart_threshold=size + 1), + ) cached_etag = cls.get_etag(s3, to_info.bucket, to_info.path) if etag != cached_etag: