@@ -173,13 +173,12 @@ def test_push_equality_between_parent_and_child_fields(self):
173
173
query = ctx .captured_queries [0 ]["sql" ]
174
174
self .assertEqual (
175
175
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)])}])" ,
185
184
)
0 commit comments