This commit is contained in:
Steve Pulec 2015-10-30 10:05:53 -04:00
parent fe2126b727
commit 015e7ea9a2

View File

@ -18,7 +18,8 @@ class KinesisResponse(BaseResponse):
@property
def is_firehose(self):
return self.headers['host'].startswith('firehose')
host = self.headers.get('hose', self.headers['Host'])
return host.startswith('firehose')
def create_stream(self):
stream_name = self.parameters.get('StreamName')