Skip to content

Commit

Permalink
Adding default headers to get bucket call.
Browse files Browse the repository at this point in the history
  • Loading branch information
danilop committed Jun 16, 2014
1 parent efa5e7a commit a7ff943
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions yas3fs/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -698,7 +698,7 @@ def __init__(self, options):
if not self.s3:
error_and_exit("no S3 connection")
try:
self.s3_bucket = self.s3.get_bucket(self.s3_bucket_name)
self.s3_bucket = self.s3.get_bucket(self.s3_bucket_name, headers=self.default_headers)
except boto.exception.S3ResponseError:
error_and_exit("S3 bucket not found")

Expand Down Expand Up @@ -993,7 +993,7 @@ def process_message(self, messages):
self.s3_prefix = s3url.path.strip('/')
logger.info("S3 prefix: '%s'" % self.s3_prefix)
try:
self.s3_bucket = self.s3.get_bucket(self.s3_bucket_name)
self.s3_bucket = self.s3.get_bucket(self.s3_bucket_name, headers=self.default_headers)
except boto.exception.S3ResponseError:
error_and_exit("S3 bucket not found")
elif c[1] == 'cache':
Expand Down

0 comments on commit a7ff943

Please sign in to comment.