From a9f551f065761c3b3e89e12300f10a92191ecc93 Mon Sep 17 00:00:00 2001 From: DailyDreaming Date: Sat, 23 Nov 2019 21:39:23 -0800 Subject: [PATCH 1/3] Sync metadata for small s3 objects. --- dss/stepfunctions/s3copyclient/implementation.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/dss/stepfunctions/s3copyclient/implementation.py b/dss/stepfunctions/s3copyclient/implementation.py index 9fa5da8aa9..3c99e8e453 100644 --- a/dss/stepfunctions/s3copyclient/implementation.py +++ b/dss/stepfunctions/s3copyclient/implementation.py @@ -70,7 +70,11 @@ 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, + ContentType=blobinfo['ContentType']) event[_Key.UPLOAD_ID] = None event[Key.FINISHED] = True event[Key.CONTENT_TYPE] = blobinfo['ContentType'] From fcb2e4db6b46643a688e62b3b7c4b14dfed4c600 Mon Sep 17 00:00:00 2001 From: Lon Blauvelt Date: Sat, 23 Nov 2019 22:04:37 -0800 Subject: [PATCH 2/3] Update implementation.py --- dss/stepfunctions/s3copyclient/implementation.py | 1 + 1 file changed, 1 insertion(+) diff --git a/dss/stepfunctions/s3copyclient/implementation.py b/dss/stepfunctions/s3copyclient/implementation.py index 3c99e8e453..3537c7cca4 100644 --- a/dss/stepfunctions/s3copyclient/implementation.py +++ b/dss/stepfunctions/s3copyclient/implementation.py @@ -74,6 +74,7 @@ def setup_copy_task(event, lambda_context): source_key, destination_bucket, destination_key, + # TODO: change to "content_type" when cloud_blobstore change is made ContentType=blobinfo['ContentType']) event[_Key.UPLOAD_ID] = None event[Key.FINISHED] = True From ddc8f04b9a02ace09db376a1a2117cf7939eb5ce Mon Sep 17 00:00:00 2001 From: Lon Blauvelt Date: Sat, 23 Nov 2019 22:05:36 -0800 Subject: [PATCH 3/3] Update implementation.py --- dss/stepfunctions/s3copyclient/implementation.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dss/stepfunctions/s3copyclient/implementation.py b/dss/stepfunctions/s3copyclient/implementation.py index 3537c7cca4..897a9e2864 100644 --- a/dss/stepfunctions/s3copyclient/implementation.py +++ b/dss/stepfunctions/s3copyclient/implementation.py @@ -74,7 +74,7 @@ def setup_copy_task(event, lambda_context): source_key, destination_bucket, destination_key, - # TODO: change to "content_type" when cloud_blobstore change is made + # TODO: change to "content_type" to be consistent with cloud_blobstore syntax? ContentType=blobinfo['ContentType']) event[_Key.UPLOAD_ID] = None event[Key.FINISHED] = True