allow index to not exist in sagemaker chunks

This commit is contained in:
Ishaan Jaff 2024-08-15 19:45:59 -07:00
parent b93152e978
commit e1839c8da2

View file

@ -808,16 +808,11 @@ class AWSEventStreamDecoder:
self.model = model
self.parser = EventStreamJSONParser()
self.content_blocks: List = []
self.index = 0
def _chunk_parser(self, chunk_data: dict) -> GChunk:
verbose_logger.debug("in sagemaker chunk parser, chunk_data %s", chunk_data)
_token = chunk_data.get("token", {}) or {}
_index = chunk_data.get("index", None)
if _index is None:
_index = self.index
self.index += 1
_index = chunk_data.get("index", None) or 0
is_finished = False
finish_reason = ""