File tree Expand file tree Collapse file tree 2 files changed +6
-5
lines changed
tests/storage/v2/elasticsearch Expand file tree Collapse file tree 2 files changed +6
-5
lines changed Original file line number Diff line number Diff line change @@ -98,14 +98,15 @@ def _build_composite(self, groupby):
9898 sources = []
9999 for elem in groupby :
100100 if elem == 'type' :
101- sources .append ({'type' : {'terms' : {'field' : 'type' }}})
101+ sources .append ({'type' : {'terms' : {'field' : 'type.keyword ' }}})
102102 elif elem == 'time' :
103103 # Not doing a date_histogram aggregation because we don't know
104104 # the period
105105 sources .append ({'begin' : {'terms' : {'field' : 'start' }}})
106106 sources .append ({'end' : {'terms' : {'field' : 'end' }}})
107107 else :
108- sources .append ({elem : {'terms' : {'field' : 'groupby.' + elem }}})
108+ field = 'groupby.' + elem + '.keyword'
109+ sources .append ({elem : {'terms' : {'field' : field }}})
109110
110111 return {"sources" : sources }
111112
Original file line number Diff line number Diff line change @@ -86,9 +86,9 @@ def test_build_composite(self):
8686 self .assertEqual (
8787 self .client ._build_composite (['one' , 'type' , 'two' ]),
8888 {'sources' : [
89- {'one' : {'terms' : {'field' : 'groupby.one' }}},
90- {'type' : {'terms' : {'field' : 'type' }}},
91- {'two' : {'terms' : {'field' : 'groupby.two' }}},
89+ {'one' : {'terms' : {'field' : 'groupby.one.keyword ' }}},
90+ {'type' : {'terms' : {'field' : 'type.keyword ' }}},
91+ {'two' : {'terms' : {'field' : 'groupby.two.keyword ' }}},
9292 ]},
9393 )
9494
You can’t perform that action at this time.
0 commit comments