diff --git a/libervia/backend/memory/sqla.py b/libervia/backend/memory/sqla.py index 3d6ea4d4..be891864 100644 --- a/libervia/backend/memory/sqla.py +++ b/libervia/backend/memory/sqla.py @@ -675,6 +675,10 @@ class Storage: stmt = stmt.where( exists().where(subquery.c.value == keyword) ) + if "origin" in filters: + stmt = stmt.where( + History.extra["origin"].as_string() == filters["origin"] + ) if limit is not None: stmt = stmt.limit(limit)