Modifying resetConnection to
def resetConnection(self): import boto if getattr(self, 'conn', False): self.conn.close() self.bucket = None self.conn = None self.storage_uri = None del self.conn del self.storage_uri self.storage_uri = boto.storage_uri(self.boto_uri_str) self.conn = get_connection(self.scheme, self.parsed_url, self.storage_uri) if not self.conn.lookup(self.bucket_name): if globals.s3_european_buckets: self.bucket = self.conn.create_bucket(self.bucket_name, location=Location.EU) else: self.bucket = self.conn.create_bucket(self.bucket_name) else: self.bucket = self.conn.get_bucket(self.bucket_name)
seems to resolve the issue. Although, I am not sure if this is wise (found this while trial-and-erroring through the file).
Modifying resetConnection to
def resetConnection (self):
self. conn.close( )
self.storage_ uri = None
self.storage_ uri = boto.storage_ uri(self. boto_uri_ str) self.scheme, self.parsed_url, self.storage_uri) lookup( self.bucket_ name): s3_european_ buckets:
self. bucket = self.conn. create_ bucket( self.bucket_ name,
location= Location. EU)
self. bucket = self.conn. create_ bucket( self.bucket_ name)
self. bucket = self.conn. get_bucket( self.bucket_ name)
import boto
if getattr(self, 'conn', False):
self.bucket = None
self.conn = None
del self.conn
del self.storage_uri
self.conn = get_connection(
if not self.conn.
if globals.
else:
else:
seems to resolve the issue. Although, I am not sure if this is wise (found this while trial-and-erroring through the file).