File tree 1 file changed +18
-8
lines changed
backend/src/services/sumo_access/queries
1 file changed +18
-8
lines changed Original file line number Diff line number Diff line change 5
5
6
6
async def get_stratigraphic_column_identifier (sumo_client : SumoClient , case_id : str ) -> str :
7
7
"""Get stratigraphic column identifier for a case (assuming unique for all objects)"""
8
- params = {
9
- "query" : f"_sumo.parent_object:{ case_id } " ,
8
+ query = {
10
9
"size" : 1 ,
11
- "select" : "masterdata.smda.stratigraphic_column.identifier" ,
10
+ "query" : {
11
+ "bool" : {
12
+ "must" : [
13
+ {"match" : {"_sumo.parent_object.keyword" : case_id }},
14
+ ]
15
+ }
16
+ },
12
17
}
13
- response = await sumo_client .get_async ("/search" , params )
18
+ response = await sumo_client .post_async ("/search" , json = query )
14
19
result = response .json ()
15
20
hits = result ["hits" ]["hits" ]
16
21
return hits [0 ]["_source" ]["masterdata" ]["smda" ]["stratigraphic_column" ]["identifier" ]
17
22
18
23
19
24
async def get_field_identifiers (sumo_client : SumoClient , case_id : str ) -> List [str ]:
20
25
"""Get field identifiers for a case (assuming unique for all objects)"""
21
- params = {
22
- "query" : f"_sumo.parent_object:{ case_id } " ,
26
+ query = {
23
27
"size" : 1 ,
24
- "select" : "masterdata.smda.field.identifier" ,
28
+ "query" : {
29
+ "bool" : {
30
+ "must" : [
31
+ {"match" : {"_sumo.parent_object.keyword" : case_id }},
32
+ ]
33
+ }
34
+ },
25
35
}
26
- response = await sumo_client .get_async ("/search" , params )
36
+ response = await sumo_client .post_async ("/search" , json = query )
27
37
result = response .json ()
28
38
hits = result ["hits" ]["hits" ]
29
39
fields = hits [0 ]["_source" ]["masterdata" ]["smda" ]["field" ]
You can’t perform that action at this time.
0 commit comments