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 @@ -174,9 +174,9 @@ def build_query(self, columns=None):
174
174
"""Check if the query is supported and prepare a MongoQuery."""
175
175
self .check_query ()
176
176
query = self .query_class (self )
177
- query .project_fields = self ._get_project_fields (columns )
177
+ query .project_fields = self .get_project_fields (columns )
178
178
query .lookup_pipeline = self .get_lookup_pipeline ()
179
- query .annotation_stage = self ._get_group_pipeline ()
179
+ query .annotation_stage = self .get_group_pipeline ()
180
180
try :
181
181
query .mongo_query = {"$expr" : self .query .where .as_mql (self , self .connection )}
182
182
except FullResultSet :
@@ -281,7 +281,7 @@ def get_lookup_pipeline(self):
281
281
result += self .query .alias_map [alias ].as_mql (self , self .connection )
282
282
return result
283
283
284
- def _get_group_pipeline (self ):
284
+ def get_group_pipeline (self ):
285
285
pipeline = None
286
286
if any (isinstance (a , Aggregate ) for a in self .query .annotations .values ()):
287
287
result = {}
@@ -322,7 +322,7 @@ def _get_group_pipeline(self):
322
322
323
323
return pipeline
324
324
325
- def _get_project_fields (self , columns = None ):
325
+ def get_project_fields (self , columns = None ):
326
326
fields = {}
327
327
for name , expr in columns or []:
328
328
try :
You can’t perform that action at this time.
0 commit comments