1- from collections import defaultdict
2-
31from pydantic import TypeAdapter
42from sqlalchemy import select
53from sqlalchemy .orm import Session
@@ -62,7 +60,7 @@ async def get_latest_hours(
6260
6361 async def get_latest_currencies (
6462 self , db : Session , league_ids : list [int ]
65- ) -> dict [ int , list [Currency ] ]:
63+ ) -> list [Currency ]:
6664 latest_hours = self ._latest_hours_stmt (league_ids ).subquery ()
6765
6866 stmt = select (model_Currency ).join (
@@ -72,13 +70,9 @@ async def get_latest_currencies(
7270 )
7371 currencies = db .scalars (stmt ).all ()
7472
75- latest_currencies : dict [int , list [Currency ]] = defaultdict (list )
76- for currency in currencies :
77- latest_currencies [currency .leagueId ].append (currency )
78-
79- validate = TypeAdapter (dict [int , list [Currency ]]).validate_python
73+ validate = TypeAdapter (list [Currency ]).validate_python
8074
81- return validate (latest_currencies )
75+ return validate (currencies )
8276
8377 async def get_currency_from_query (
8478 self , db : Session , query_list : list [CurrencyQuery ]
0 commit comments