Returned ETag for uploaded entities

s3transfer/tasks.py

@@ -377,11 +377,17 @@ def _main(self, client, bucket, key, upload_id, parts, extra_args):
             ``UploadPartTask.main()``.
         :param extra_args:  A dictionary of any extra arguments that may be
             used in completing the multipart transfer.
+        :returns: A dictionary representing metadata information about the
+            upload, such as the ETag for the uploaded entity.
         """
-        client.complete_multipart_upload(
+        response = client.complete_multipart_upload(
             Bucket=bucket,
             Key=key,
             UploadId=upload_id,
             MultipartUpload={'Parts': parts},
             **extra_args,
         )
+        metadata = dict()
+        if 'ETag' in response:
+            metadata['ETag'] = response['ETag']
+        return metadata

s3transfer/upload.py

@@ -753,9 +753,16 @@ def _main(self, client, fileobj, bucket, key, extra_args):
         :param key: The name of the key to upload to
         :param extra_args: A dictionary of any extra arguments that may be
             used in the upload.
+        :returns: A dictionary representing metadata information about the
+            upload, such as the ETag for the uploaded entity.
         """
         with fileobj as body:
-            client.put_object(Bucket=bucket, Key=key, Body=body, **extra_args)
+            response = client.put_object(Bucket=bucket, Key=key, Body=body,
+                **extra_args)
+            metadata = dict()
+            if 'ETag' in response:
+                metadata['ETag'] = response['ETag']
+            return metadata
 
 
 class UploadPartTask(Task):

tests/unit/test_tasks.py

@@ -779,7 +779,8 @@ def test_main(self):
 class TestCompleteMultipartUploadTask(BaseMultipartTaskTest):
     def test_main(self):
         upload_id = 'my-id'
-        parts = [{'ETag': 'etag', 'PartNumber': 0}]
+        parts = [{'ETag': 'part-etag', 'PartNumber': 0}]
+        etag = 'uploaded-etag'
         task = self.get_task(
             CompleteMultipartUploadTask,
             main_kwargs={
@@ -793,15 +794,17 @@ def test_main(self):
         )
         self.stubber.add_response(
             method='complete_multipart_upload',
-            service_response={},
+            service_response={'ETag': etag},
             expected_params={
                 'Bucket': self.bucket,
                 'Key': self.key,
                 'UploadId': upload_id,
                 'MultipartUpload': {'Parts': parts},
             },
         )
-        task()
+        task_response = task()
+        self.assertIn("ETag", task_response)
+        self.assertEqual(task_response["ETag"], etag)
         self.stubber.assert_no_pending_responses()
 
     def test_includes_extra_args(self):

tests/unit/test_upload.py

@@ -631,6 +631,7 @@ def test_submits_tag_for_multipart_fileobj(self):
 class TestPutObjectTask(BaseUploadTest):
     def test_main(self):
         extra_args = {'Metadata': {'foo': 'bar'}}
+        etag = 'uploaded-etag'
         with open(self.filename, 'rb') as fileobj:
             task = self.get_task(
                 PutObjectTask,
@@ -644,15 +645,17 @@ def test_main(self):
             )
             self.stubber.add_response(
                 method='put_object',
-                service_response={},
+                service_response={'ETag': etag},
                 expected_params={
                     'Body': ANY,
                     'Bucket': self.bucket,
                     'Key': self.key,
                     'Metadata': {'foo': 'bar'},
                 },
             )
-            task()
+            task_response = task()
+            self.assertIn("ETag", task_response)
+            self.assertEqual(task_response["ETag"], etag)
             self.stubber.assert_no_pending_responses()
             self.assertEqual(self.sent_bodies, [self.content])