8000 fix: Generate Python Code from `plugin-pb` (#99) · cloudquery/plugin-pb-python@8375eeb · GitHub
[go: up one dir, main page]
Skip to content {"props":{"docsUrl":"https://docs.github.com/get-started/accessibility/keyboard-shortcuts"}}

Commit 8375eeb

Browse files
cq-botcq-bot
authored
fix: Generate Python Code from plugin-pb (#99)
This PR was created by a scheduled workflow to regenerate the Python code from `plugin-pb`.
1 parent c183780 commit 8375eeb

File tree

3 files changed

+73
-9
lines changed

3 files changed

+73
-9
lines changed

‎cloudquery/plugin_v3/plugin_pb2.py

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

‎cloudquery/plugin_v3/plugin_pb2.pyi

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -243,6 +243,20 @@ class Transform(_message.Message):
243243
def __init__(self, record: _Optional[bytes] = ...) -> None: ...
244244
def __init__(self) -> None: ...
245245

246+
class TransformSchema(_message.Message):
247+
__slots__ = ()
248+
class Request(_message.Message):
249+
__slots__ = ("schema",)
250+
SCHEMA_FIELD_NUMBER: _ClassVar[int]
251+
schema: bytes
252+
def __init__(self, schema: _Optional[bytes] = ...) -> None: ...
253+
class Response(_message.Message):
254+
__slots__ = ("schema",)
255+
SCHEMA_FIELD_NUMBER: _ClassVar[int]
256+
schema: bytes
257+
def __init__(self, schema: _Optional[bytes] = ...) -> None: ...
258+
def __init__(self) -> None: ...
259+
246260
class Close(_message.Message):
247261
__slots__ = ()
248262
class Request(_message.Message):

‎cloudquery/plugin_v3/plugin_pb2_grpc.py

Lines changed: 44 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -84,6 +84,11 @@ def __init__(self, channel):
8484
request_serializer=cloudquery_dot_plugin__v3_dot_plugin__pb2.Transform.Request.SerializeToString,
8585
response_deserializer=cloudquery_dot_plugin__v3_dot_plugin__pb2.Transform.Response.FromString,
8686
_registered_method=True)
87+
self.TransformSchema = channel.stream_stream(
88+
'/cloudquery.plugin.v3.Plugin/TransformSchema',
89+
request_serializer=cloudquery_dot_plugin__v3_dot_plugin__pb2.TransformSchema.Request.SerializeToString,
90+
response_deserializer=cloudquery_dot_plugin__v3_dot_plugin__pb2.TransformSchema.Response.FromString,
91+
_registered_method=True)
8792
self.Close = channel.unary_unary(
8893
'/cloudquery.plugin.v3.Plugin/Close',
8994
request_serializer=cloudquery_dot_plugin__v3_dot_plugin__pb2.Close.Request.SerializeToString,
@@ -165,6 +170,13 @@ def Transform(self, request_iterator, context):
165170
context.set_details('Method not implemented!')
166171
raise NotImplementedError('Method not implemented!')
167172

173+
def TransformSchema(self, request_iterator, context):
174+
"""Transform schemas.
175+
"""
176+
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
177+
context.set_details('Method not implemented!')
178+
raise NotImplementedError('Method not implemented!')
179+
168180
def Close(self, request, context):
169181
"""Send signal to flush and close open connections
170182
"""
@@ -227,6 +239,11 @@ def add_PluginServicer_to_server(servicer, server):
227239
request_deserializer=cloudquery_dot_plugin__v3_dot_plugin__pb2.Transform.Request.FromString,
228240
response_serializer=cloudquery_dot_plugin__v3_dot_plugin__pb2.Transform.Response.SerializeToString,
229241
),
242+
'TransformSchema': grpc.stream_stream_rpc_method_handler(
243+
servicer.TransformSchema,
244+
request_deserializer=cloudquery_dot_plugin__v3_dot_plugin__pb2.TransformSchema.Request.FromString,
245+
response_serializer=cloudquery_dot_plugin__v3_dot_plugin__pb2.TransformSchema.Response.SerializeToString,
246+
),
230247
'Close': grpc.unary_unary_rpc_method_handler(
231248
servicer.Close,
232249
request_deserializer=cloudquery_dot_plugin__v3_dot_plugin__pb2.Close.Request.FromString,
@@ -491,6 +508,33 @@ def Transform(request_iterator,
491508
metadata,
492509
_registered_method=True)
493510

511+
@staticmethod
512+
def TransformSchema(request_iterator,
513+
target,
514+
options=(),
515+
channel_credentials=None,
516+
call_credentials=None,
517+
insecure=False,
518+
compression=None,
519+
wait_for_ready=None,
520+
timeout=None,
521+
metadata=None):
522+
return grpc.experimental.stream_stream(
523+
request_iterator,
524+
target,
525+
'/cloudquery.plugin.v3.Plugin/TransformSchema',
526+
cloudquery_dot_plugin__v3_dot_plugin__pb2.TransformSchema.Request.SerializeToString,
527+
cloudquery_dot_plugin__v3_dot_plugin__pb2.TransformSchema.Response.FromString,
528+
options,
529+
channel_credentials,
530+
insecure,
531+
call_credentials,
532+
compression,
533+
wait_for_ready,
534+
timeout,
535+
metadata,
536+
_registered_method=True)
537+
494538
@staticmethod
495539
def Close(request,
496540
target,

0 commit comments

Comments
 (0)
0