add missing await

Author: sleepyStick

test/asynchronous/test_encryption.py

@@ -2493,7 +2493,7 @@ async def test_1(self):
                 kms_providers={"local": {"key": LOCAL_MASTER_KEY}},
             )
         )
-        doc = anext(
+        doc = await anext(
             await self.encrypted_client.db.csfle.aggregate(
                 [
                     {"$match": {"csfle": "csfle"}},
@@ -2522,7 +2522,7 @@ async def test_2(self):
                 kms_providers={"local": {"key": LOCAL_MASTER_KEY}},
             )
         )
-        doc = anext(
+        doc = await anext(
             await self.encrypted_client.db.qe.aggregate(
                 [
                     {"$match": {"qe": "qe"}},
@@ -2551,7 +2551,7 @@ async def test_3(self):
                 kms_providers={"local": {"key": LOCAL_MASTER_KEY}},
             )
         )
-        doc = anext(
+        doc = await anext(
             await self.encrypted_client.db.no_schema.aggregate(
                 [
                     {"$match": {"no_schema": "no_schema"}},
@@ -2577,7 +2577,7 @@ async def test_4(self):
                 kms_providers={"local": {"key": LOCAL_MASTER_KEY}},
             )
         )
-        doc = anext(
+        doc = await anext(
             await self.encrypted_client.db.no_schema.aggregate(
                 [
                     {"$match": {"no_schema": "no_schema"}},
@@ -2606,7 +2606,7 @@ async def test_5(self):
                 kms_providers={"local": {"key": LOCAL_MASTER_KEY}},
             )
         )
-        doc = anext(
+        doc = await anext(
             await self.encrypted_client.db.csfle.aggregate(
                 [
                     {"$match": {"csfle": "csfle"}},
@@ -2635,7 +2635,7 @@ async def test_6(self):
                 kms_providers={"local": {"key": LOCAL_MASTER_KEY}},
             )
         )
-        doc = anext(
+        doc = await anext(
             await self.encrypted_client.db.qe.aggregate(
                 [
                     {"$match": {"qe": "qe"}},
@@ -2664,7 +2664,7 @@ async def test_7(self):
                 kms_providers={"local": {"key": LOCAL_MASTER_KEY}},
             )
         )
-        doc = anext(
+        doc = await anext(
             await self.encrypted_client.db.no_schema.aggregate(
                 [
                     {"$match": {"no_schema": "no_schema"}},
@@ -2695,7 +2695,7 @@ async def test_8(self):
         )
         # not sure if this is the right error!
         with self.assertRaises(PyMongoError) as exc:
-            _ = anext(
+            _ = await anext(
                 await self.encrypted_client.db.no_schema.aggregate(
                     [
                         {"$match": {"no_schema": "no_schema"}},
@@ -2727,7 +2727,7 @@ async def test_9(self):
         )
         # not sure if this is the right error!
         with self.assertRaises(PyMongoError) as exc:
-            _ = anext(
+            _ = await anext(
                 await self.encrypted_client.db.csfle.aggregate(
                     [
                         {"$match": {"csfle": "csfle"}},