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