Verify put object options

api/python/quilt3/data_transfer.py

@@ -352,16 +352,14 @@ def upload_part(i, start, end):
             nonlocal remaining
             part_id = i + 1
             with ReadFileChunk.from_filename(src_path, start, end-start, [ctx.progress]) as fd:
-                s3_upload_params = dict(
+                part = s3_client.upload_part(
                     Body=fd,
                     Bucket=dest_bucket,
                     Key=dest_key,
                     UploadId=upload_id,
                     PartNumber=part_id,
-                    ChecksumAlgorithm='SHA256',
+                    ChecksumAlgorithm="SHA256",
                 )
-                add_put_options_safely(s3_upload_params, put_options)
-                part = s3_client.upload_part(**s3_upload_params)
             with lock:
                 parts[i] = dict(
                     PartNumber=part_id,
@@ -372,13 +370,6 @@ def upload_part(i, start, end):
                 done = remaining == 0
 
             if done:
-                s3_complete_params = dict(
-                    Bucket=dest_bucket,
-                    Key=dest_key,
-                    UploadId=upload_id,
-                    MultipartUpload={'Parts': parts},
-                )
-                add_put_options_safely(s3_complete_params, put_options)
                 resp = s3_client.complete_multipart_upload(
                     Bucket=dest_bucket,
                     Key=dest_key,
@@ -520,16 +511,14 @@ def _copy_remote_file(ctx: WorkerContext, size: int, src_bucket: str, src_key: s
         def upload_part(i, start, end):
             nonlocal remaining
             part_id = i + 1
-            s3_upload_params = dict(
+            part = s3_client.upload_part_copy(
                 CopySource=src_params,
-                CopySourceRange=f'bytes={start}-{end-1}',
+                CopySourceRange=f"bytes={start}-{end-1}",
                 Bucket=dest_bucket,
                 Key=dest_key,
                 UploadId=upload_id,
                 PartNumber=part_id,
             )
-            add_put_options_safely(s3_upload_params, extra_args)
-            part = s3_client.upload_part_copy(**s3_upload_params)
             with lock:
                 parts[i] = dict(
                     PartNumber=part_id,
@@ -548,7 +537,6 @@ def upload_part(i, start, end):
                     UploadId=upload_id,
                     MultipartUpload={'Parts': parts},
                 )
-                add_put_options_safely(s3_complete_params, extra_args)
                 resp = s3_client.complete_multipart_upload(**s3_complete_params)
                 version_id = resp.get('VersionId')  # Absent in unversioned buckets.
                 checksum, _ = resp['ChecksumSHA256'].split('-', 1)