Update to new select api

HHS · Jan 2, 2025 · 3b63968 · 3b63968
1 parent 898ad5b
commit 3b63968
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/api/src/services/users/get_saved_opportunities.py b/api/src/services/users/get_saved_opportunities.py
@@ -1,6 +1,8 @@
 import logging
 from uuid import UUID
 
+from sqlalchemy import select
+
 from src.adapters import db
 from src.db.models.opportunity_models import Opportunity
 from src.db.models.user_models import UserSavedOpportunity
@@ -11,9 +13,11 @@
 def get_saved_opportunities(db_session: db.Session, user_id: UUID) -> list[UserSavedOpportunity]:
     logger.info(f"Getting saved opportunities for user {user_id}")
 
-    return (
-        db_session.query(UserSavedOpportunity)
+    stmt = (
+        select(UserSavedOpportunity)
         .join(Opportunity)
-        .filter(UserSavedOpportunity.user_id == user_id)
-        .all()
+        .where(UserSavedOpportunity.user_id == user_id)
     )
+
+    result = db_session.execute(stmt)
+    return list(result.scalars().all())