diff --git a/src/mass/adapters/outbound/utils.py b/src/mass/adapters/outbound/utils.py index 6287955..a3f220c 100644 --- a/src/mass/adapters/outbound/utils.py +++ b/src/mass/adapters/outbound/utils.py @@ -62,7 +62,7 @@ def pipeline_match_filters_stage(*, filters: list[models.Filter]) -> JsonObject: "$or": [ { "$and": [ - {key: {"$type": "string"}}, + {key: {"$not": {"$type": "array"}}}, {key: {"$in": values}}, ] },