|
@@ -7,7 +7,7 @@ class ElasticSearchStrategy:
|
|
|
|
|
|
async def base_search(
|
|
|
self,
|
|
|
- filters: Dict[str, str],
|
|
|
+ filters: Dict[str, List],
|
|
|
text_query: str = None,
|
|
|
_source=False,
|
|
|
size: int = 10000,
|
|
@@ -15,7 +15,7 @@ class ElasticSearchStrategy:
|
|
|
) -> List:
|
|
|
must_clauses = []
|
|
|
for field, value in filters.items():
|
|
|
- must_clauses.append({"term": {field: value}})
|
|
|
+ must_clauses.append({"terms": {field: value}})
|
|
|
|
|
|
if text_query:
|
|
|
must_clauses.append({"match": {"topic": text_query}})
|