fix test 8

sleepyStick · sleepyStick · commit 74fac795f8ca · 2025-03-18T19:07:03.000-07:00
diff --git a/test/asynchronous/test_encryption.py b/test/asynchronous/test_encryption.py
@@ -2696,24 +2696,20 @@ async def test_8(self):
         # not sure if this is the right error!
         with self.assertRaises(PyMongoError) as exc:
             _ = await anext(
-                await self.encrypted_client.db.no_schema.aggregate(
+                await self.encrypted_client.db.csfle.aggregate(
                     [
-                        {"$match": {"no_schema": "no_schema"}},
+                        {"$match": {"csfle": "qe"}},
                         {
                             "$lookup": {
-                                "from": "no_schema2",
+                                "from": "qe",
                                 "as": "matched",
-                                "pipeline": [
-                                    {"$match": {"no_schema2": "no_schema2"}},
-                                    {"$project": {"_id": 0}},
-                                ],
+                                "pipeline": [{"$match": {"qe": "qe"}}, {"$project": {"_id": 0}}],
                             }
                         },
                         {"$project": {"_id": 0}},
                     ]
                 )
             )
-            # check that the exc contains the substring not supported
             self.assertTrue("not supported" in str(exc))
 
     # Test requires mongocryptd/crypt_shared <8.1.
@@ -2745,7 +2741,6 @@ async def test_9(self):
                     ]
                 )
             )
-            # check that the exc contains the substring Upgrade
             self.assertTrue("Upgrade" in str(exc))
 
 
diff --git a/test/test_encryption.py b/test/test_encryption.py
@@ -2680,24 +2680,20 @@ def test_8(self):
         # not sure if this is the right error!
         with self.assertRaises(PyMongoError) as exc:
             _ = next(
-                self.encrypted_client.db.no_schema.aggregate(
+                self.encrypted_client.db.csfle.aggregate(
                     [
-                        {"$match": {"no_schema": "no_schema"}},
+                        {"$match": {"csfle": "qe"}},
                         {
                             "$lookup": {
-                                "from": "no_schema2",
+                                "from": "qe",
                                 "as": "matched",
-                                "pipeline": [
-                                    {"$match": {"no_schema2": "no_schema2"}},
-                                    {"$project": {"_id": 0}},
-                                ],
+                                "pipeline": [{"$match": {"qe": "qe"}}, {"$project": {"_id": 0}}],
                             }
                         },
                         {"$project": {"_id": 0}},
                     ]
                 )
             )
-            # check that the exc contains the substring not supported
             self.assertTrue("not supported" in str(exc))
 
     # Test requires mongocryptd/crypt_shared <8.1.
@@ -2729,7 +2725,6 @@ def test_9(self):
                     ]
                 )
             )
-            # check that the exc contains the substring Upgrade
             self.assertTrue("Upgrade" in str(exc))
 
 

Original file line number	Diff line number	Diff line change
`@@ -2696,24 +2696,20 @@ async def test_8(self):`
`2696`	`2696`	`# not sure if this is the right error!`
`2697`	`2697`	`with self.assertRaises(PyMongoError) as exc:`
`2698`	`2698`	`_ = await anext(`
`2699`		`- await self.encrypted_client.db.no_schema.aggregate(`
	`2699`	`+ await self.encrypted_client.db.csfle.aggregate(`
`2700`	`2700`	`[`
`2701`		`- {"$match": {"no_schema": "no_schema"}},`
	`2701`	`+ {"$match": {"csfle": "qe"}},`
`2702`	`2702`	`{`
`2703`	`2703`	`"$lookup": {`
`2704`		`- "from": "no_schema2",`
	`2704`	`+ "from": "qe",`
`2705`	`2705`	`"as": "matched",`
`2706`		`- "pipeline": [`
`2707`		`- {"$match": {"no_schema2": "no_schema2"}},`
`2708`		`- {"$project": {"_id": 0}},`
`2709`		`- ],`
	`2706`	`+ "pipeline": [{"$match": {"qe": "qe"}}, {"$project": {"_id": 0}}],`
`2710`	`2707`	`}`
`2711`	`2708`	`},`
`2712`	`2709`	`{"$project": {"_id": 0}},`
`2713`	`2710`	`]`
`2714`	`2711`	`)`
`2715`	`2712`	`)`
`2716`		`- # check that the exc contains the substring not supported`
`2717`	`2713`	`self.assertTrue("not supported" in str(exc))`
`2718`	`2714`
`2719`	`2715`	`# Test requires mongocryptd/crypt_shared <8.1.`
`@@ -2745,7 +2741,6 @@ async def test_9(self):`
`2745`	`2741`	`]`
`2746`	`2742`	`)`
`2747`	`2743`	`)`
`2748`		`- # check that the exc contains the substring Upgrade`
`2749`	`2744`	`self.assertTrue("Upgrade" in str(exc))`
`2750`	`2745`
`2751`	`2746`
Original file line number	Diff line number	Diff line change
`@@ -2680,24 +2680,20 @@ def test_8(self):`
`2680`	`2680`	`# not sure if this is the right error!`
`2681`	`2681`	`with self.assertRaises(PyMongoError) as exc:`
`2682`	`2682`	`_ = next(`
`2683`		`- self.encrypted_client.db.no_schema.aggregate(`
	`2683`	`+ self.encrypted_client.db.csfle.aggregate(`
`2684`	`2684`	`[`
`2685`		`- {"$match": {"no_schema": "no_schema"}},`
	`2685`	`+ {"$match": {"csfle": "qe"}},`
`2686`	`2686`	`{`
`2687`	`2687`	`"$lookup": {`
`2688`		`- "from": "no_schema2",`
	`2688`	`+ "from": "qe",`
`2689`	`2689`	`"as": "matched",`
`2690`		`- "pipeline": [`
`2691`		`- {"$match": {"no_schema2": "no_schema2"}},`
`2692`		`- {"$project": {"_id": 0}},`
`2693`		`- ],`
	`2690`	`+ "pipeline": [{"$match": {"qe": "qe"}}, {"$project": {"_id": 0}}],`
`2694`	`2691`	`}`
`2695`	`2692`	`},`
`2696`	`2693`	`{"$project": {"_id": 0}},`
`2697`	`2694`	`]`
`2698`	`2695`	`)`
`2699`	`2696`	`)`
`2700`		`- # check that the exc contains the substring not supported`
`2701`	`2697`	`self.assertTrue("not supported" in str(exc))`
`2702`	`2698`
`2703`	`2699`	`# Test requires mongocryptd/crypt_shared <8.1.`
`@@ -2729,7 +2725,6 @@ def test_9(self):`
`2729`	`2725`	`]`
`2730`	`2726`	`)`
`2731`	`2727`	`)`
`2732`		`- # check that the exc contains the substring Upgrade`
`2733`	`2728`	`self.assertTrue("Upgrade" in str(exc))`
`2734`	`2729`
`2735`	`2730`