diff --git a/backend/src/services/sumo_access/queries/case.py b/backend/src/services/sumo_access/queries/case.py index 7f1895451..7100a5b1c 100644 --- a/backend/src/services/sumo_access/queries/case.py +++ b/backend/src/services/sumo_access/queries/case.py @@ -5,12 +5,17 @@ async def get_stratigraphic_column_identifier(sumo_client: SumoClient, case_id: str) -> str: """Get stratigraphic column identifier for a case (assuming unique for all objects)""" - params = { - "query": f"_sumo.parent_object:{case_id}", + query = { "size": 1, - "select": "masterdata.smda.stratigraphic_column.identifier", + "query": { + "bool": { + "must": [ + {"match": {"_sumo.parent_object.keyword": case_id}}, + ] + } + }, } - response = await sumo_client.get_async("/search", params) + response = await sumo_client.post_async("/search", json=query) result = response.json() hits = result["hits"]["hits"] return hits[0]["_source"]["masterdata"]["smda"]["stratigraphic_column"]["identifier"] @@ -18,12 +23,17 @@ async def get_stratigraphic_column_identifier(sumo_client: SumoClient, case_id: async def get_field_identifiers(sumo_client: SumoClient, case_id: str) -> List[str]: """Get field identifiers for a case (assuming unique for all objects)""" - params = { - "query": f"_sumo.parent_object:{case_id}", + query = { "size": 1, - "select": "masterdata.smda.field.identifier", + "query": { + "bool": { + "must": [ + {"match": {"_sumo.parent_object.keyword": case_id}}, + ] + } + }, } - response = await sumo_client.get_async("/search", params) + response = await sumo_client.post_async("/search", json=query) result = response.json() hits = result["hits"]["hits"] fields = hits[0]["_source"]["masterdata"]["smda"]["field"]