diff --git a/dss/stepfunctions/s3copyclient/implementation.py b/dss/stepfunctions/s3copyclient/implementation.py index 9fa5da8aa9..897a9e2864 100644 --- a/dss/stepfunctions/s3copyclient/implementation.py +++ b/dss/stepfunctions/s3copyclient/implementation.py @@ -70,7 +70,12 @@ def setup_copy_task(event, lambda_context): event[_Key.UPLOAD_ID] = mpu['UploadId'] event[Key.FINISHED] = False else: - s3_blobstore.copy(source_bucket, source_key, destination_bucket, destination_key) + s3_blobstore.copy(source_bucket, + source_key, + destination_bucket, + destination_key, + # TODO: change to "content_type" to be consistent with cloud_blobstore syntax? + ContentType=blobinfo['ContentType']) event[_Key.UPLOAD_ID] = None event[Key.FINISHED] = True event[Key.CONTENT_TYPE] = blobinfo['ContentType']