Skip to content

Commit dc11ff9

Browse files
yandex-cloud-botyandex-cloud-bot
committed
feat: regenerate proto
1 parent b607320 commit dc11ff9

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

43 files changed

+2487
-748
lines changed

‎cloudapi‎

Submodule cloudapi updated 17 files

‎yandex/cloud/airflow/v1/cluster_service_pb2.py‎

Lines changed: 48 additions & 41 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎yandex/cloud/airflow/v1/cluster_service_pb2_grpc.py‎

Lines changed: 133 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33
import grpc
44
import warnings
55

6+
from yandex.cloud.access import access_pb2 as yandex_dot_cloud_dot_access_dot_access__pb2
67
from yandex.cloud.airflow.v1 import cluster_pb2 as yandex_dot_cloud_dot_airflow_dot_v1_dot_cluster__pb2
78
from yandex.cloud.airflow.v1 import cluster_service_pb2 as yandex_dot_cloud_dot_airflow_dot_v1_dot_cluster__service__pb2
89
from yandex.cloud.operation import operation_pb2 as yandex_dot_cloud_dot_operation_dot_operation__pb2
@@ -77,6 +78,21 @@ def __init__(self, channel):
7778
request_serializer=yandex_dot_cloud_dot_airflow_dot_v1_dot_cluster__service__pb2.ListClusterOperationsRequest.SerializeToString,
7879
response_deserializer=yandex_dot_cloud_dot_airflow_dot_v1_dot_cluster__service__pb2.ListClusterOperationsResponse.FromString,
7980
_registered_method=True)
81+
self.ListAccessBindings = channel.unary_unary(
82+
'/yandex.cloud.airflow.v1.ClusterService/ListAccessBindings',
83+
request_serializer=yandex_dot_cloud_dot_access_dot_access__pb2.ListAccessBindingsRequest.SerializeToString,
84+
response_deserializer=yandex_dot_cloud_dot_access_dot_access__pb2.ListAccessBindingsResponse.FromString,
85+
_registered_method=True)
86+
self.SetAccessBindings = channel.unary_unary(
87+
'/yandex.cloud.airflow.v1.ClusterService/SetAccessBindings',
88+
request_serializer=yandex_dot_cloud_dot_access_dot_access__pb2.SetAccessBindingsRequest.SerializeToString,
89+
response_deserializer=yandex_dot_cloud_dot_operation_dot_operation__pb2.Operation.FromString,
90+
_registered_method=True)
91+
self.UpdateAccessBindings = channel.unary_unary(
92+
'/yandex.cloud.airflow.v1.ClusterService/UpdateAccessBindings',
93+
request_serializer=yandex_dot_cloud_dot_access_dot_access__pb2.UpdateAccessBindingsRequest.SerializeToString,
94+
response_deserializer=yandex_dot_cloud_dot_operation_dot_operation__pb2.Operation.FromString,
95+
_registered_method=True)
8096

8197

8298
class ClusterServiceServicer(object):
@@ -139,6 +155,27 @@ def ListOperations(self, request, context):
139155
context.set_details('Method not implemented!')
140156
raise NotImplementedError('Method not implemented!')
141157

158+
def ListAccessBindings(self, request, context):
159+
"""Retrieves a list of access bindings for the specified Apache Airflow cluster.
160+
"""
161+
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
162+
context.set_details('Method not implemented!')
163+
raise NotImplementedError('Method not implemented!')
164+
165+
def SetAccessBindings(self, request, context):
166+
"""Sets access bindings for the specified Apache Airflow cluster.
167+
"""
168+
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
169+
context.set_details('Method not implemented!')
170+
raise NotImplementedError('Method not implemented!')
171+
172+
def UpdateAccessBindings(self, request, context):
173+
"""Updates access bindings for the specified Apache Airflow cluster.
174+
"""
175+
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
176+
context.set_details('Method not implemented!')
177+
raise NotImplementedError('Method not implemented!')
178+
142179

143180
def add_ClusterServiceServicer_to_server(servicer, server):
144181
rpc_method_handlers = {
@@ -182,6 +219,21 @@ def add_ClusterServiceServicer_to_server(servicer, server):
182219
request_deserializer=yandex_dot_cloud_dot_airflow_dot_v1_dot_cluster__service__pb2.ListClusterOperationsRequest.FromString,
183220
response_serializer=yandex_dot_cloud_dot_airflow_dot_v1_dot_cluster__service__pb2.ListClusterOperationsResponse.SerializeToString,
184221
),
222+
'ListAccessBindings': grpc.unary_unary_rpc_method_handler(
223+
servicer.ListAccessBindings,
224+
request_deserializer=yandex_dot_cloud_dot_access_dot_access__pb2.ListAccessBindingsRequest.FromString,
225+
response_serializer=yandex_dot_cloud_dot_access_dot_access__pb2.ListAccessBindingsResponse.SerializeToString,
226+
),
227+
'SetAccessBindings': grpc.unary_unary_rpc_method_handler(
228+
servicer.SetAccessBindings,
229+
request_deserializer=yandex_dot_cloud_dot_access_dot_access__pb2.SetAccessBindingsRequest.FromString,
230+
response_serializer=yandex_dot_cloud_dot_operation_dot_operation__pb2.Operation.SerializeToString,
231+
),
232+
'UpdateAccessBindings': grpc.unary_unary_rpc_method_handler(
233+
servicer.UpdateAccessBindings,
234+
request_deserializer=yandex_dot_cloud_dot_access_dot_access__pb2.UpdateAccessBindingsRequest.FromString,
235+
response_serializer=yandex_dot_cloud_dot_operation_dot_operation__pb2.Operation.SerializeToString,
236+
),
185237
}
186238
generic_handler = grpc.method_handlers_generic_handler(
187239
'yandex.cloud.airflow.v1.ClusterService', rpc_method_handlers)
@@ -409,3 +461,84 @@ def ListOperations(request,
409461
timeout,
410462
metadata,
411463
_registered_method=True)
464+
465+
@staticmethod
466+
def ListAccessBindings(request,
467+
target,
468+
options=(),
469+
channel_credentials=None,
470+
call_credentials=None,
471+
insecure=False,
472+
compression=None,
473+
wait_for_ready=None,
474+
timeout=None,
475+
metadata=None):
476+
return grpc.experimental.unary_unary(
477+
request,
478+
target,
479+
'/yandex.cloud.airflow.v1.ClusterService/ListAccessBindings',
480+
yandex_dot_cloud_dot_access_dot_access__pb2.ListAccessBindingsRequest.SerializeToString,
481+
yandex_dot_cloud_dot_access_dot_access__pb2.ListAccessBindingsResponse.FromString,
482+
options,
483+
channel_credentials,
484+
insecure,
485+
call_credentials,
486+
compression,
487+
wait_for_ready,
488+
timeout,
489+
metadata,
490+
_registered_method=True)
491+
492+
@staticmethod
493+
def SetAccessBindings(request,
494+
target,
495+
options=(),
496+
channel_credentials=None,
497+
call_credentials=None,
498+
insecure=False,
499+
compression=None,
500+
wait_for_ready=None,
501+
timeout=None,
502+
metadata=None):
503+
return grpc.experimental.unary_unary(
504+
request,
505+
target,
506+
'/yandex.cloud.airflow.v1.ClusterService/SetAccessBindings',
507+
yandex_dot_cloud_dot_access_dot_access__pb2.SetAccessBindingsRequest.SerializeToString,
508+
yandex_dot_cloud_dot_operation_dot_operation__pb2.Operation.FromString,
509+
options,
510+
channel_credentials,
511+
insecure,
512+
call_credentials,
513+
compression,
514+
wait_for_ready,
515+
timeout,
516+
metadata,
517+
_registered_method=True)
518+
519+
@staticmethod
520+
def UpdateAccessBindings(request,
521+
target,
522+
options=(),
523+
channel_credentials=None,
524+
call_credentials=None,
525+
insecure=False,
526+
compression=None,
527+
wait_for_ready=None,
528+
timeout=None,
529+
metadata=None):
530+
return grpc.experimental.unary_unary(
531+
request,
532+
target,
533+
'/yandex.cloud.airflow.v1.ClusterService/UpdateAccessBindings',
534+
yandex_dot_cloud_dot_access_dot_access__pb2.UpdateAccessBindingsRequest.SerializeToString,
535+
yandex_dot_cloud_dot_operation_dot_operation__pb2.Operation.FromString,
536+
options,
537+
channel_credentials,
538+
insecure,
539+
call_credentials,
540+
compression,
541+
wait_for_ready,
542+
timeout,
543+
metadata,
544+
_registered_method=True)

‎yandex/cloud/airflow/v1/cluster_service_pb2_grpc.pyi‎

Lines changed: 61 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@ import collections.abc
88
import grpc
99
import grpc.aio
1010
import typing
11+
import yandex.cloud.access.access_pb2
1112
import yandex.cloud.airflow.v1.cluster_pb2
1213
import yandex.cloud.airflow.v1.cluster_service_pb2
1314
import yandex.cloud.operation.operation_pb2
@@ -71,6 +72,24 @@ class ClusterServiceStub:
7172
]
7273
"""Retrieves the list of Operation resources for the specified cluster."""
7374

75+
ListAccessBindings: grpc.UnaryUnaryMultiCallable[
76+
yandex.cloud.access.access_pb2.ListAccessBindingsRequest,
77+
yandex.cloud.access.access_pb2.ListAccessBindingsResponse,
78+
]
79+
"""Retrieves a list of access bindings for the specified Apache Airflow cluster."""
80+
81+
SetAccessBindings: grpc.UnaryUnaryMultiCallable[
82+
yandex.cloud.access.access_pb2.SetAccessBindingsRequest,
83+
yandex.cloud.operation.operation_pb2.Operation,
84+
]
85+
"""Sets access bindings for the specified Apache Airflow cluster."""
86+
87+
UpdateAccessBindings: grpc.UnaryUnaryMultiCallable[
88+
yandex.cloud.access.access_pb2.UpdateAccessBindingsRequest,
89+
yandex.cloud.operation.operation_pb2.Operation,
90+
]
91+
"""Updates access bindings for the specified Apache Airflow cluster."""
92+
7493
class ClusterServiceAsyncStub:
7594
"""A set of methods for managing Apache Airflow Cluster resources."""
7695

@@ -122,6 +141,24 @@ class ClusterServiceAsyncStub:
122141
]
123142
"""Retrieves the list of Operation resources for the specified cluster."""
124143

144+
ListAccessBindings: grpc.aio.UnaryUnaryMultiCallable[
145+
yandex.cloud.access.access_pb2.ListAccessBindingsRequest,
146+
yandex.cloud.access.access_pb2.ListAccessBindingsResponse,
147+
]
148+
"""Retrieves a list of access bindings for the specified Apache Airflow cluster."""
149+
150+
SetAccessBindings: grpc.aio.UnaryUnaryMultiCallable[
151+
yandex.cloud.access.access_pb2.SetAccessBindingsRequest,
152+
yandex.cloud.operation.operation_pb2.Operation,
153+
]
154+
"""Sets access bindings for the specified Apache Airflow cluster."""
155+
156+
UpdateAccessBindings: grpc.aio.UnaryUnaryMultiCallable[
157+
yandex.cloud.access.access_pb2.UpdateAccessBindingsRequest,
158+
yandex.cloud.operation.operation_pb2.Operation,
159+
]
160+
"""Updates access bindings for the specified Apache Airflow cluster."""
161+
125162
class ClusterServiceServicer(metaclass=abc.ABCMeta):
126163
"""A set of methods for managing Apache Airflow Cluster resources."""
127164

@@ -189,4 +226,28 @@ class ClusterServiceServicer(metaclass=abc.ABCMeta):
189226
) -> typing.Union[yandex.cloud.airflow.v1.cluster_service_pb2.ListClusterOperationsResponse, collections.abc.Awaitable[yandex.cloud.airflow.v1.cluster_service_pb2.ListClusterOperationsResponse]]:
190227
"""Retrieves the list of Operation resources for the specified cluster."""
191228

229+
@abc.abstractmethod
230+
def ListAccessBindings(
231+
self,
232+
request: yandex.cloud.access.access_pb2.ListAccessBindingsRequest,
233+
context: _ServicerContext,
234+
) -> typing.Union[yandex.cloud.access.access_pb2.ListAccessBindingsResponse, collections.abc.Awaitable[yandex.cloud.access.access_pb2.ListAccessBindingsResponse]]:
235+
"""Retrieves a list of access bindings for the specified Apache Airflow cluster."""
236+
237+
@abc.abstractmethod
238+
def SetAccessBindings(
239+
self,
240+
request: yandex.cloud.access.access_pb2.SetAccessBindingsRequest,
241+
context: _ServicerContext,
242+
) -> typing.Union[yandex.cloud.operation.operation_pb2.Operation, collections.abc.Awaitable[yandex.cloud.operation.operation_pb2.Operation]]:
243+
"""Sets access bindings for the specified Apache Airflow cluster."""
244+
245+
@abc.abstractmethod
246+
def UpdateAccessBindings(
247+
self,
248+
request: yandex.cloud.access.access_pb2.UpdateAccessBindingsRequest,
249+
context: _ServicerContext,
250+
) -> typing.Union[yandex.cloud.operation.operation_pb2.Operation, collections.abc.Awaitable[yandex.cloud.operation.operation_pb2.Operation]]:
251+
"""Updates access bindings for the specified Apache Airflow cluster."""
252+
192253
def add_ClusterServiceServicer_to_server(servicer: ClusterServiceServicer, server: typing.Union[grpc.Server, grpc.aio.Server]) -> None: ...

0 commit comments

Comments
 (0)