style refactor

Author: slampy97

tests/coordination/test_coordination_client.py

@@ -1,7 +1,6 @@
 import asyncio
 import threading
 import time
-from cgitb import small
 
 import pytest
 
@@ -17,6 +16,7 @@
     DescribeLockResult,
 )
 
+
 @pytest.fixture
 def sync_coordination_node(driver_sync):
     client = CoordinationClient(driver_sync)
@@ -43,6 +43,7 @@ def sync_coordination_node(driver_sync):
     except ydb.SchemeError:
         pass
 
+
 @pytest.fixture
 async def async_coordination_node(aio_connection):
     client = aio.CoordinationClient(aio_connection)
@@ -146,7 +147,6 @@ async def test_coordination_lock_describe_full_async(self, async_coordination_no
         assert list(desc2.owners) == []
         assert list(desc2.waiters) == []
 
-
         delete = await lock.delete()
         assert delete.status == StatusCode.SUCCESS
 
@@ -248,7 +248,7 @@ def second_lock_task():
                     lock2_acquired.set()
                     logger.info("Second thread acquired lock")
             except Exception as e:
-                logger.exception("second_lock_task failed")
+                logger.exception(f"{e} | second_lock_task failed")
 
         t2 = threading.Thread(target=second_lock_task)
 

ydb/aio/coordination/lock.py

@@ -1,6 +1,5 @@
 import asyncio
 import contextlib
-from typing import Optional
 
 from ydb import issues
 from ydb._grpc.grpcwrapper.ydb_coordination import (
@@ -13,7 +12,6 @@
     FromServer,
 )
 from ydb._grpc.grpcwrapper.ydb_coordination_public_types import CreateSemaphoreResult, DescribeLockResult
-from ydb.aio.coordination.stream import CoordinationStream
 from ydb.aio.coordination.reconnector import CoordinationReconnector