File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -143,9 +143,9 @@ def build_query(self, columns=None):
143
143
"""Check if the query is supported and prepare a MongoQuery."""
144
144
self .check_query ()
145
145
query = self .query_class (self )
146
- query .project_fields = self ._get_project_fields (columns )
146
+ query .project_fields = self .get_project_fields (columns )
147
147
query .lookup_pipeline = self .get_lookup_pipeline ()
148
- query .annotation_stage = self ._get_group_pipeline ()
148
+ query .annotation_stage = self .get_group_pipeline ()
149
149
try :
150
150
query .mongo_query = {"$expr" : self .query .where .as_mql (self , self .connection )}
151
151
except FullResultSet :
@@ -244,7 +244,7 @@ def get_lookup_pipeline(self):
244
244
result += self .query .alias_map [alias ].as_mql (self , self .connection )
245
245
return result
246
246
247
- def _get_group_pipeline (self ):
247
+ def get_group_pipeline (self ):
248
248
pipeline = None
249
249
if any (isinstance (a , Aggregate ) for a in self .query .annotations .values ()):
250
250
result = {}
@@ -285,7 +285,7 @@ def _get_group_pipeline(self):
285
285
286
286
return pipeline
287
287
288
- def _get_project_fields (self , columns = None ):
288
+ def get_project_fields (self , columns = None ):
289
289
fields = {}
290
290
for name , expr in columns or []:
291
291
try :
You can’t perform that action at this time.
0 commit comments