easier fallback.
This commit is contained in:
		
							parent
							
								
									127625bdc3
								
							
						
					
					
						commit
						7fcf84b32a
					
				| @ -18,7 +18,7 @@ class KinesisResponse(BaseResponse): | |||||||
| 
 | 
 | ||||||
|     @property |     @property | ||||||
|     def is_firehose(self): |     def is_firehose(self): | ||||||
|         host = self.headers.get('host', self.headers['Host']) |         host = self.headers.get('host') or self.headers['Host'] | ||||||
|         return host.startswith('firehose') |         return host.startswith('firehose') | ||||||
| 
 | 
 | ||||||
|     def create_stream(self): |     def create_stream(self): | ||||||
|  | |||||||
		Loading…
	
	
			
			x
			
			
		
	
		Reference in New Issue
	
	Block a user