forked from phoenix/litellm-mirror
(fix) select_data_generator
This commit is contained in:
parent
a61dbc1613
commit
44e213e842
1 changed files with 16 additions and 7 deletions
|
@ -1423,13 +1423,22 @@ async def async_data_generator(response, user_api_key_dict):
|
||||||
|
|
||||||
|
|
||||||
def select_data_generator(response, user_api_key_dict):
|
def select_data_generator(response, user_api_key_dict):
|
||||||
# since boto3 - sagemaker does not support async calls
|
try:
|
||||||
if response.custom_llm_provider == "sagemaker":
|
# since boto3 - sagemaker does not support async calls, we should use a sync data_generator
|
||||||
return data_generator(
|
if (
|
||||||
response=response,
|
hasattr(response, "custom_llm_provider")
|
||||||
)
|
and response.custom_llm_provider == "sagemaker"
|
||||||
else:
|
):
|
||||||
# default to async_data_generator
|
return data_generator(
|
||||||
|
response=response,
|
||||||
|
)
|
||||||
|
else:
|
||||||
|
# default to async_data_generator
|
||||||
|
return async_data_generator(
|
||||||
|
response=response, user_api_key_dict=user_api_key_dict
|
||||||
|
)
|
||||||
|
except:
|
||||||
|
# worst case - use async_data_generator
|
||||||
return async_data_generator(
|
return async_data_generator(
|
||||||
response=response, user_api_key_dict=user_api_key_dict
|
response=response, user_api_key_dict=user_api_key_dict
|
||||||
)
|
)
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue