diff --git a/server/internal/shared/retrieval/qdrant.go b/server/internal/shared/retrieval/qdrant.go index 8397c29..ebb2d13 100644 --- a/server/internal/shared/retrieval/qdrant.go +++ b/server/internal/shared/retrieval/qdrant.go @@ -195,9 +195,7 @@ func (s *qdrantStore) Search(ctx context.Context, req SearchRequest) ([]SearchPo } groupIDs := normalizeGroupIDs(req.GroupIDs) if len(groupIDs) > 0 { - filter.Should = []*sdk.Condition{ - sdk.NewMatchInts("group_id", groupIDs...), - } + filter.Must = append(filter.Must, sdk.NewMatchInts("group_id", groupIDs...)) } points, err := s.client.Query(ctx, &sdk.QueryPoints{