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 :
@@ -250,7 +250,7 @@ def get_lookup_pipeline(self):
250
250
result += self .query .alias_map [alias ].as_mql (self , self .connection )
251
251
return result
252
252
253
- def _get_group_pipeline (self ):
253
+ def get_group_pipeline (self ):
254
254
pipeline = None
255
255
if any (isinstance (a , Aggregate ) for a in self .query .annotations .values ()):
256
256
result = {}
@@ -291,7 +291,7 @@ def _get_group_pipeline(self):
291
291
292
292
return pipeline
293
293
294
- def _get_project_fields (self , columns = None ):
294
+ def get_project_fields (self , columns = None ):
295
295
fields = {}
296
296
for name , expr in columns or []:
297
297
try :
You can’t perform that action at this time.
0 commit comments