File tree Expand file tree Collapse file tree 5 files changed +25
-23
lines changed
Expand file tree Collapse file tree 5 files changed +25
-23
lines changed Original file line number Diff line number Diff line change 55import pytest
66
77import ydb
8- from ydb import aio , StatusCode , logger
8+ from ydb .aio .coordination import CoordinationClient as AioCoordinationClient
9+ from ydb import StatusCode , logger
910
1011from ydb .coordination import (
1112 NodeConfig ,
@@ -46,7 +47,7 @@ def sync_coordination_node(driver_sync):
4647
4748@pytest .fixture
4849async def async_coordination_node (aio_connection ):
49- client = aio . CoordinationClient (aio_connection )
50+ client = AioCoordinationClient (aio_connection )
5051 node_path = "/local/test_node"
5152
5253 try :
Original file line number Diff line number Diff line change 11from typing import Optional
22
3- from ydb ._grpc .grpcwrapper .ydb_coordination import (
3+ from .. ._grpc .grpcwrapper .ydb_coordination import (
44 CreateNodeRequest ,
55 DescribeNodeRequest ,
66 AlterNodeRequest ,
77 DropNodeRequest ,
88)
9- from ydb ._grpc .grpcwrapper .ydb_coordination_public_types import NodeConfig
10- from ydb . coordination .base_coordination_client import BaseCoordinationClient
9+ from .. ._grpc .grpcwrapper .ydb_coordination_public_types import NodeConfig
10+ from ... coordination .base import BaseCoordinationClient
1111
12- from ydb . aio . coordination .lock import CoordinationLock
12+ from .lock import CoordinationLock
1313
1414
1515class CoordinationClient (BaseCoordinationClient ):
Original file line number Diff line number Diff line change 1- from .coordination_client import CoordinationClient
2-
3- from ydb ._grpc .grpcwrapper .ydb_coordination_public_types import (
4- NodeConfig ,
5- ConsistencyMode ,
6- RateLimiterCountersMode ,
7- DescribeResult ,
8- CreateSemaphoreResult ,
9- DescribeLockResult ,
10- )
11-
121__all__ = [
132 "CoordinationClient" ,
143 "NodeConfig" ,
187 "CreateSemaphoreResult" ,
198 "DescribeLockResult" ,
209]
10+
11+ from .client import CoordinationClient
12+
13+
14+ from .._grpc .grpcwrapper .ydb_coordination_public_types import (
15+ NodeConfig ,
16+ ConsistencyMode ,
17+ RateLimiterCountersMode ,
18+ DescribeResult ,
19+ CreateSemaphoreResult ,
20+ DescribeLockResult ,
21+ )
Original file line number Diff line number Diff line change 1- from ydb import _apis , issues
2- from ydb ._grpc .grpcwrapper .ydb_coordination_public_types import NodeConfig , DescribeResult
1+ from .. import _apis , issues
2+ from . ._grpc .grpcwrapper .ydb_coordination_public_types import NodeConfig , DescribeResult
33import logging
44
55
Original file line number Diff line number Diff line change 11from typing import Optional
22
3- from ydb ._grpc .grpcwrapper .ydb_coordination import (
3+ from . ._grpc .grpcwrapper .ydb_coordination import (
44 CreateNodeRequest ,
55 DescribeNodeRequest ,
66 AlterNodeRequest ,
77 DropNodeRequest ,
88)
9- from ydb ._grpc .grpcwrapper .ydb_coordination_public_types import NodeConfig
10- from ydb . coordination . base_coordination_client import BaseCoordinationClient
11- from ydb . coordination .lock_sync import CoordinationLockSync
9+ from . ._grpc .grpcwrapper .ydb_coordination_public_types import NodeConfig
10+ from . base import BaseCoordinationClient
11+ from .lock_sync import CoordinationLockSync
1212
1313
1414class CoordinationClient (BaseCoordinationClient ):
You can’t perform that action at this time.
0 commit comments