move PQv0 proto to kikimr/yndx/api KIKIMR-13879

init

ref:9003253
sync: https://proxy.sandbox.yandex-team.ru/2690348971

Author: BogolyubskiyAlexey

.github/workflows/main.yaml

@@ -959,7 +959,7 @@ def start(self):
         """
         Start actor. Async
         :return: concurrent.futures.Future.
-        Future result will be protobuf kikimr/public/api/protos/draft/persqueue.proto::<RequestType>::Init
+        Future result will be protobuf kikimr/yndx/api/protos/persqueue.proto::<RequestType>::Init
         Request type is ReadResponse OR WriteResponse depending on type of actor
         """
         self.__pqlib._start_actor(self._actor_uid)

persqueue/_core.py

@@ -5,8 +5,8 @@
 
 import enum
 
-from kikimr.public.api.protos.draft.persqueue_pb2 import WriteRequest, ReadRequest
-from kikimr.public.api.protos.draft.persqueue_pb2 import WriteResponse, ReadResponse
+from kikimr.yndx.api.protos.persqueue_pb2 import WriteRequest, ReadRequest
+from kikimr.yndx.api.protos.persqueue_pb2 import WriteResponse, ReadResponse
 
 import kikimr.public.api.protos.draft.persqueue_error_codes_pb2 as pq_err_codes
 import kikimr.public.api.protos.ydb_persqueue_cluster_discovery_pb2 as cds_proto

persqueue/_protobuf.py

@@ -8,13 +8,13 @@
 from ydb.credentials import YDB_AUTH_TICKET_HEADER
 
 from kikimr.public.sdk.python.persqueue import errors
-from kikimr.public.api.protos.draft import persqueue_pb2
+from kikimr.public.api.protos.draft import persqueue_common_pb2
 
 
 @six.add_metaclass(abc.ABCMeta)
 class CredentialsProvider(object):
     def __init__(self):
-        self._cached_proto = persqueue_pb2.Credentials()
+        self._cached_proto = persqueue_common_pb2.Credentials()
 
     @abc.abstractmethod
     def _build_protobuf(self):

persqueue/auth.py

@@ -3,7 +3,7 @@
 
 import logging
 
-import kikimr.public.api.grpc.draft.persqueue_pb2_grpc as pqv0_server
+import kikimr.yndx.api.grpc.persqueue_pb2_grpc as pqv0_server
 import kikimr.public.api.grpc.draft.ydb_persqueue_v1_pb2_grpc as pqv1_server
 from ydb.pool import ConnectionPool
 from ydb.settings import BaseRequestSettings

persqueue/channel.py

@@ -60,7 +60,7 @@ def write(self, seq_no, data, create_time_ms=None, codec=None):
         :param create_time_ms: optional
         :param codec: optional
         :return: concurrent.futures.Future.
-        Future result will be protobuf kikimr/public/api/protos/draft/persqueue.proto::WriteResponse
+        Future result will be protobuf kikimr/yndx/api/protos/persqueue.proto::WriteResponse
         """
         WriterCodec.is_codec_valid(codec)
         args = {
@@ -75,7 +75,7 @@ def write_batch(self, data_batch, create_time_ms=None, codec=None):
         :param create_time_ms: optional
         :param codec: optional
         :return: concurrent.futures.Future.
-        Future result will be protobuf kikimr/public/api/protos/persqueue.proto::WriteResponse
+        Future result will be protobuf kikimr/yndx/api/protos/persqueue.proto::WriteResponse
         """
         WriterCodec.is_codec_valid(codec)
         args = {
@@ -208,7 +208,7 @@ class ProducerConfigurator(collections.namedtuple(
 )):
     """
     Configurator class for PQStreaming writers. Keeps all WriteSession parameters and used for Producer initialization.
-    See kikimr/public/api/protos/draft/persqueue.proto`:TWriteRequest:TInit to learn more about parameters.
+    See kikimr/yndx/api/protos/persqueue.proto`:TWriteRequest:TInit to learn more about parameters.
     """
     def __new__(
         cls, topic, source_id, partition_group=None, deadline=None, preferred_datacenter=None, extra_fields=None
@@ -241,7 +241,7 @@ class ConsumerConfigurator(collections.namedtuple(
 )):
     """
     Configurator class for PQStreaming readers. Keeps all ReadSession parameters and used for Consumer initialization.
-    See kikimr/public/api/protos/draft/persqueue.proto:ReadRequest to learn more about parameters.
+    See kikimr/yndx/api/protos/persqueue.proto:ReadRequest to learn more about parameters.
 
     Note: unlike ProducerConfigurator, who's parameter are only used for session init,
     parameters from ConsumerConfigurator will be also used in further read requests (max_count, max_size, etc.)