refac: valves
This commit is contained in:
parent
b8086c5edf
commit
b25c7da154
|
@ -431,8 +431,10 @@ async def update_function_valves_by_id(
|
||||||
try:
|
try:
|
||||||
form_data = {k: v for k, v in form_data.items() if v is not None}
|
form_data = {k: v for k, v in form_data.items() if v is not None}
|
||||||
valves = Valves(**form_data)
|
valves = Valves(**form_data)
|
||||||
Functions.update_function_valves_by_id(id, valves.model_dump())
|
|
||||||
return valves.model_dump()
|
valves_dict = valves.model_dump(exclude_unset=True)
|
||||||
|
Functions.update_function_valves_by_id(id, valves_dict)
|
||||||
|
return valves_dict
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
log.exception(f"Error updating function values by id {id}: {e}")
|
log.exception(f"Error updating function values by id {id}: {e}")
|
||||||
raise HTTPException(
|
raise HTTPException(
|
||||||
|
@ -514,10 +516,11 @@ async def update_function_user_valves_by_id(
|
||||||
try:
|
try:
|
||||||
form_data = {k: v for k, v in form_data.items() if v is not None}
|
form_data = {k: v for k, v in form_data.items() if v is not None}
|
||||||
user_valves = UserValves(**form_data)
|
user_valves = UserValves(**form_data)
|
||||||
|
user_valves_dict = user_valves.model_dump(exclude_unset=True)
|
||||||
Functions.update_user_valves_by_id_and_user_id(
|
Functions.update_user_valves_by_id_and_user_id(
|
||||||
id, user.id, user_valves.model_dump()
|
id, user.id, user_valves_dict
|
||||||
)
|
)
|
||||||
return user_valves.model_dump()
|
return user_valves_dict
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
log.exception(f"Error updating function user valves by id {id}: {e}")
|
log.exception(f"Error updating function user valves by id {id}: {e}")
|
||||||
raise HTTPException(
|
raise HTTPException(
|
||||||
|
|
|
@ -486,8 +486,9 @@ async def update_tools_valves_by_id(
|
||||||
try:
|
try:
|
||||||
form_data = {k: v for k, v in form_data.items() if v is not None}
|
form_data = {k: v for k, v in form_data.items() if v is not None}
|
||||||
valves = Valves(**form_data)
|
valves = Valves(**form_data)
|
||||||
Tools.update_tool_valves_by_id(id, valves.model_dump())
|
valves_dict = valves.model_dump(exclude_unset=True)
|
||||||
return valves.model_dump()
|
Tools.update_tool_valves_by_id(id, valves_dict)
|
||||||
|
return valves_dict
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
log.exception(f"Failed to update tool valves by id {id}: {e}")
|
log.exception(f"Failed to update tool valves by id {id}: {e}")
|
||||||
raise HTTPException(
|
raise HTTPException(
|
||||||
|
@ -562,10 +563,11 @@ async def update_tools_user_valves_by_id(
|
||||||
try:
|
try:
|
||||||
form_data = {k: v for k, v in form_data.items() if v is not None}
|
form_data = {k: v for k, v in form_data.items() if v is not None}
|
||||||
user_valves = UserValves(**form_data)
|
user_valves = UserValves(**form_data)
|
||||||
|
user_valves_dict = user_valves.model_dump(exclude_unset=True)
|
||||||
Tools.update_user_valves_by_id_and_user_id(
|
Tools.update_user_valves_by_id_and_user_id(
|
||||||
id, user.id, user_valves.model_dump()
|
id, user.id, user_valves_dict
|
||||||
)
|
)
|
||||||
return user_valves.model_dump()
|
return user_valves_dict
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
log.exception(f"Failed to update user valves by id {id}: {e}")
|
log.exception(f"Failed to update user valves by id {id}: {e}")
|
||||||
raise HTTPException(
|
raise HTTPException(
|
||||||
|
|
Loading…
Reference in New Issue