@@ -173,13 +173,12 @@ def test_push_equality_between_parent_and_child_fields(self):
173173 query = ctx .captured_queries [0 ]["sql" ]
174174 self .assertEqual (
175175 query ,
176- "db.queries__order.aggregate([{'$lookup': {'from': "
177- "'queries__orderitem', 'let': {'parent__field__0': '$_id', "
178- "'parent__field__1': '$queries__orderitem.status'}, 'pipeline': "
179- "[{'$match': {'$expr': {'$and': [{'$eq': ['$$parent__field__0', "
180- "'$order_id']}, {'$eq': ['$status', '$$parent__field__1']}]}}}], "
181- "'as': 'queries__orderitem'}}, {'$unwind': "
182- "'$queries__orderitem'}, {'$match': {'$expr': {'$eq': "
183- "['$queries__orderitem.status', '$_id']}}}, {'$addFields': "
184- "{'_id': '$_id'}}, {'$sort': SON([('_id', 1)])}])" ,
176+ "db.queries__order.aggregate([{'$lookup': {'from': 'queries__orderitem', "
177+ "'let': {'parent__field__0': '$_id', 'parent__field__1': '$_id'}, "
178+ "'pipeline': [{'$match': {'$expr': {'$and': [{'$eq': "
179+ "['$$parent__field__0', '$order_id']}, {'$eq': ['$status', "
180+ "'$$parent__field__1']}]}}}], 'as': 'queries__orderitem'}}, "
181+ "{'$unwind': '$queries__orderitem'}, {'$match': {'$expr': "
182+ "{'$eq': ['$queries__orderitem.status', '$_id']}}}, "
183+ "{'$addFields': {'_id': '$_id'}}, {'$sort': SON([('_id', 1)])}])" ,
185184 )
0 commit comments