Merge branch 'refs/heads/main' into basic-example

Author: rekby

CHANGELOG.md

@@ -1,8 +1,8 @@
 ## 3.9.1 ##
-* Relaxed requirements for pyjwt version from exactly 2.8.0 to >= 2.0
+yanked bad api release
 
 ## 3.9.0 ##
-* Supported nebius jwt credentials, added requirements for pyjwt==2.8.0
+yanked bad api release
 
 ## 3.8.1 ##
 * Fixed to handle deadline on topic stream in async driver.

examples/topic/basic_example.py

@@ -50,10 +50,16 @@ async def main():
     )
     parser.add_argument("-d", "--database", default="/local", help="Name of the database to use")
     parser.add_argument("-e", "--endpoint", default="grpc://localhost:2136", help="Endpoint url to use")
-    parser.add_argument("-p", "--path",  default="test-topic", help="Topic name")
+    parser.add_argument("-p", "--path", default="test-topic", help="Topic name")
     parser.add_argument("-c", "--consumer", default="consumer", help="Consumer name")
     parser.add_argument("-v", "--verbose", default=False, action="store_true")
-    parser.add_argument("-s", "--skip-drop-and-create-topic", default=False, action="store_true", help="Use existed topic, skip remove it and re-create")
+    parser.add_argument(
+        "-s",
+        "--skip-drop-and-create-topic",
+        default=False,
+        action="store_true",
+        help="Use existed topic, skip remove it and re-create",
+    )
 
     args = parser.parse_args()
 
@@ -72,5 +78,5 @@ async def main():
     )
 
 
-if __name__ == '__main__':
-    asyncio.run(main())
+if __name__ == "__main__":
+    asyncio.run(main())

requirements.txt

@@ -2,4 +2,3 @@ grpcio>=1.42.0
 packaging
 protobuf>=3.13.0,<5.0.0
 aiohttp<4
-pyjwt>=2.0.0

test-requirements.txt

@@ -30,7 +30,6 @@ pytest-asyncio==0.21.0
 pytest-docker-compose==3.2.1
 python-dotenv==0.18.0
 PyYAML==5.3.1
-pyjwt==2.0.0
 requests==2.31.0
 texttable==1.6.4
 toml==0.10.2
@@ -47,5 +46,4 @@ pylint-protobuf
 cython
 freezegun==1.2.2
 pytest-cov
-yandexcloud
 -e .

tests/aio/test_credentials.py

@@ -38,6 +38,17 @@ def test_tx_begin(driver_sync, database):
     tx.rollback()
 
 
+def test_credentials():
+    credentials = ydb.iam.MetadataUrlCredentials()
+    raised = False
+    try:
+        credentials.auth_metadata()
+    except Exception:
+        raised = True
+
+    assert raised
+
+
 def test_tx_snapshot_ro(driver_sync, database):
     session = driver_sync.table_client.session().create()
     description = (