mohammadian7/freqtrade
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Don''t use deprecated pydantic methods

Browse Source
This commit is contained in:
Matthias
2023-07-18 18:22:36 +02:00
parent bb18e1b45b
commit 47850ce1b0
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
freqtrade/rpc/api_server/api_ws.py
+3 -3
View File
@@ -65,7 +65,7 @@ async def _process_consumer_request(
""" """
# Validate the request, makes sure it matches the schema # Validate the request, makes sure it matches the schema
try: try:
websocket_request = WSRequestSchema.parse_obj(request) websocket_request = WSRequestSchema.model_validate(request)
except ValidationError as e: except ValidationError as e:
logger.error(f"Invalid request from {channel}: {e}") logger.error(f"Invalid request from {channel}: {e}")
return return
@@ -94,7 +94,7 @@ async def _process_consumer_request(
# Format response # Format response
response = WSWhitelistMessage(data=whitelist) response = WSWhitelistMessage(data=whitelist)
await channel.send(response.dict(exclude_none=True)) await channel.send(response.model_dump(exclude_none=True))
elif type_ == RPCRequestType.ANALYZED_DF: elif type_ == RPCRequestType.ANALYZED_DF:
# Limit the amount of candles per dataframe to 'limit' or 1500 # Limit the amount of candles per dataframe to 'limit' or 1500
@@ -105,7 +105,7 @@ async def _process_consumer_request(
for message in rpc._ws_request_analyzed_df(limit, pair): for message in rpc._ws_request_analyzed_df(limit, pair):
# Format response # Format response
response = WSAnalyzedDFMessage(data=message) response = WSAnalyzedDFMessage(data=message)
await channel.send(response.dict(exclude_none=True)) await channel.send(response.model_dump(exclude_none=True))
@router.websocket("/message/ws") @router.websocket("/message/ws")