diff --git a/resolvers/reader.py b/resolvers/reader.py index 3290cbe8..8b732174 100644 --- a/resolvers/reader.py +++ b/resolvers/reader.py @@ -306,7 +306,7 @@ async def load_shouts_search(_, _info, text, limit=50, offset=0): shout_id = str(shout_id) scores[shout_id] = sr.get("score") hits_ids.append(shout_id) - result = local_session().execute(query_shouts()).unique() + result = local_session().execute(query_shouts().filter(Shout.id.in_(hits_ids))) if result: logger.debug(result) shouts = []