Fix lightweight-serving no streaming resp on mtl (#11822)
This commit is contained in:
		
							parent
							
								
									e70ae0638e
								
							
						
					
					
						commit
						5a80fd2633
					
				
					 1 changed files with 2 additions and 0 deletions
				
			
		| 
						 | 
				
			
			@ -125,6 +125,7 @@ async def chat_stream_generator(local_model, delta_text_queue, request_id):
 | 
			
		|||
    model_name = local_model.model_name
 | 
			
		||||
    index = 0
 | 
			
		||||
    while True:
 | 
			
		||||
        await asyncio.sleep(0)
 | 
			
		||||
        if not hasattr(delta_text_queue, 'empty'):
 | 
			
		||||
            delta_text, remain = get_queue_next_token(delta_text_queue)
 | 
			
		||||
        else:
 | 
			
		||||
| 
						 | 
				
			
			@ -168,6 +169,7 @@ async def completion_stream_generator(local_model, delta_text_queue, request_id)
 | 
			
		|||
    model_name = local_model.model_name
 | 
			
		||||
    index = 0
 | 
			
		||||
    while True:
 | 
			
		||||
        await asyncio.sleep(0)
 | 
			
		||||
        if not hasattr(delta_text_queue, 'empty'):
 | 
			
		||||
            delta_text, remain = get_queue_next_token(delta_text_queue)
 | 
			
		||||
        else:
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
		Loading…
	
		Reference in a new issue