mirror of
https://github.com/QwenLM/Qwen.git
synced 2026-05-20 08:25:47 +08:00
bugfix streaming mode of openai_api.py
This commit is contained in:
@@ -484,7 +484,7 @@ async def predict(
|
||||
stop_words_ids = [tokenizer.encode(s)
|
||||
for s in stop_words] if stop_words else None
|
||||
|
||||
delay_token_num = max([len(x) for x in stop_words])
|
||||
delay_token_num = max([len(x) for x in stop_words]) if stop_words_ids else 0
|
||||
response_generator = model.chat_stream(tokenizer,
|
||||
query,
|
||||
history=history,
|
||||
@@ -494,7 +494,7 @@ async def predict(
|
||||
for _new_response in response_generator:
|
||||
if len(_new_response) <= delay_token_num:
|
||||
continue
|
||||
new_response = _new_response[:-delay_token_num]
|
||||
new_response = _new_response[:-delay_token_num] if delay_token_num else _new_response
|
||||
|
||||
if len(new_response) == current_length:
|
||||
continue
|
||||
|
||||
Reference in New Issue
Block a user