### What problem does this PR solve? ### Type of change - [x] Refactoringtags/v0.11.0
| else: | else: | ||||
| conv.reference[-1] = ans["reference"] | conv.reference[-1] = ans["reference"] | ||||
| conv.message[-1] = {"role": "assistant", "content": ans["answer"], "id": message_id} | conv.message[-1] = {"role": "assistant", "content": ans["answer"], "id": message_id} | ||||
| ans["id"] = message_id | |||||
| def rename_field(ans): | def rename_field(ans): | ||||
| reference = ans['reference'] | reference = ans['reference'] |
| else: conv.reference[-1] = ans["reference"] | else: conv.reference[-1] = ans["reference"] | ||||
| conv.message[-1] = {"role": "assistant", "content": ans["answer"], | conv.message[-1] = {"role": "assistant", "content": ans["answer"], | ||||
| "id": message_id, "prompt": ans.get("prompt", "")} | "id": message_id, "prompt": ans.get("prompt", "")} | ||||
| ans["id"] = message_id | |||||
| def stream(): | def stream(): | ||||
| nonlocal dia, msg, req, conv | nonlocal dia, msg, req, conv |
| _, payload = msg[0] | _, payload = msg[0] | ||||
| return Payload(self.REDIS, queue_name, group_name, msg_id, payload) | return Payload(self.REDIS, queue_name, group_name, msg_id, payload) | ||||
| except Exception as e: | except Exception as e: | ||||
| logging.warning("[EXCEPTION]xpending_range" + consumer_name + "||" + str(e)) | |||||
| if 'key' in str(e): | |||||
| return | |||||
| logging.warning("[EXCEPTION]xpending_range: " + consumer_name + "||" + str(e)) | |||||
| self.__open__() | self.__open__() | ||||
| REDIS_CONN = RedisDB() | REDIS_CONN = RedisDB() |