style fixes

Author: vgvoleg

tests/query/conftest.py

@@ -31,4 +31,4 @@ def tx(session):
 @pytest.fixture
 def pool(driver_sync):
     pool = QuerySessionPool(driver_sync)
-    yield pool
+    yield pool

tests/query/test_query_session_pool.py

@@ -26,6 +26,7 @@ def test_oneshot_query_raises(self, pool: QuerySessionPool):
     def test_retry_op_uses_created_session(self, pool: QuerySessionPool):
         def callee(session: QuerySessionSync):
             assert session._state._state == QuerySessionStateEnum.CREATED
+
         pool.retry_operation_sync(callee)
 
     def test_retry_op_normal(self, pool: QuerySessionPool):

ydb/query/base.py

@@ -202,10 +202,6 @@ def wrap_execute_query_response(rpc_state, response_pb, tx=None, commit_tx=False
     return convert.ResultSet.from_message(response_pb.result_set)
 
 
-X_YDB_SERVER_HINTS = "x-ydb-server-hints"
-X_YDB_SESSION_CLOSE = "session-close"
-
-
 def bad_session_handler(func):
     @functools.wraps(func)
     def decorator(rpc_state, response_pb, session_state, *args, **kwargs):

ydb/query/session.py

@@ -198,13 +198,13 @@ def _attach(self):
         self._state._change_state(QuerySessionStateEnum.CREATED)
 
         threading.Thread(
-            target=self._chech_session_status_loop,
+            target=self._check_session_status_loop,
             args=(status_stream,),
             name="check session status thread",
             daemon=True,
         ).start()
 
-    def _chech_session_status_loop(self, status_stream):
+    def _check_session_status_loop(self, status_stream):
         try:
             for status in status_stream:
                 if status.status != issues.StatusCode.SUCCESS: