File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -330,15 +330,12 @@ async def async_chat(
330330 ** kwargs ,
331331 )
332332
333- if not stream :
334- if response :
335- return response
336- handle_empty_response (sdk_model , attempt , self .max_retries )
337- else :
338- non_empty_stream = await self ._peek_and_rebuild_async (response )
339- if non_empty_stream :
340- return non_empty_stream
341- handle_empty_response (sdk_model , attempt , self .max_retries )
333+ if not stream and response :
334+ return response
335+ non_empty_stream = await self ._peek_and_rebuild_async (response )
336+ if non_empty_stream :
337+ return non_empty_stream
338+ handle_empty_response (sdk_model , attempt , self .max_retries )
342339 if sdk_model == model :
343340 print (f"💥 Failed to override with model '{ model } '" )
344341 except Exception as e :
@@ -384,10 +381,8 @@ def sync_chat(
384381 ** kwargs ,
385382 )
386383
387- if not stream :
388- if response :
389- return response
390- handle_empty_response (sdk_model , attempt , self .max_retries )
384+ if not stream and response :
385+ return response
391386 if stream :
392387 try :
393388 peek_iter , return_iter = itertools .tee (response )
@@ -398,9 +393,9 @@ def sync_chat(
398393 break
399394 if has_content :
400395 return return_iter
401- handle_empty_response (sdk_model , attempt , self .max_retries )
402396 except StopIteration :
403397 pass
398+ handle_empty_response (sdk_model , attempt , self .max_retries )
404399
405400 except Exception as e :
406401 if sdk_model == model :
You can’t perform that action at this time.
0 commit comments