fix s3 upload

elangovana · Sep 26, 2018 · 745a2f0 · 745a2f0
1 parent b1fde35
commit 745a2f0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/source/pipeline/OutputPathS3Mapper.py b/source/pipeline/OutputPathS3Mapper.py
@@ -52,7 +52,7 @@ def __call__(self, uripath, localpath):
     def upload_single_file(self, bucket_name, key, tempath):
         client = boto3.resource('s3')
         local_path = tempath
-        self.logger.info("Uploading to bucket {}, {} to file {}".format(bucket_name, key, local_path))
+        self.logger.info("Uploading to bucket {}, {} from file {}".format(bucket_name, key, local_path))
         with open(tempath, "rb") as data:
-            client.Bucket(bucket_name).put_object(key, data)
+            client.Object(bucket_name, key).put(Body=data)