diff --git a/src/haunt_fm/services/recommender.py b/src/haunt_fm/services/recommender.py index b99b546..324b5ce 100644 --- a/src/haunt_fm/services/recommender.py +++ b/src/haunt_fm/services/recommender.py @@ -53,9 +53,13 @@ async def get_recommendations( LIMIT :limit """) + # Format embedding as pgvector literal: [n1,n2,...] + emb = profile.embedding + emb_str = "[" + ",".join(str(float(x)) for x in emb) + "]" + result = await session.execute( query, - {"profile_embedding": str(profile.embedding), "limit": limit}, + {"profile_embedding": emb_str, "limit": limit}, ) return [