Skip to content

Commit

Permalink
pre-commit linting
Browse files Browse the repository at this point in the history
Signed-off-by: vsoch <[email protected]>
  • Loading branch information
vsoch committed Jun 29, 2024
1 parent ab53852 commit 32b41aa
Show file tree
Hide file tree
Showing 4 changed files with 446 additions and 327 deletions.
43 changes: 23 additions & 20 deletions python/v1/rainbow/protos/memory_pb2.py

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

121 changes: 73 additions & 48 deletions python/v1/rainbow/protos/memory_pb2_grpc.py
Original file line number Diff line number Diff line change
Expand Up @@ -15,15 +15,15 @@ def __init__(self, channel):
channel: A grpc.Channel.
"""
self.Satisfy = channel.unary_unary(
'/service.MemoryGraph/Satisfy',
request_serializer=memory__pb2.SatisfyRequest.SerializeToString,
response_deserializer=memory__pb2.SatisfyResponse.FromString,
)
"/service.MemoryGraph/Satisfy",
request_serializer=memory__pb2.SatisfyRequest.SerializeToString,
response_deserializer=memory__pb2.SatisfyResponse.FromString,
)
self.Register = channel.unary_unary(
'/service.MemoryGraph/Register',
request_serializer=memory__pb2.RegisterRequest.SerializeToString,
response_deserializer=memory__pb2.Response.FromString,
)
"/service.MemoryGraph/Register",
request_serializer=memory__pb2.RegisterRequest.SerializeToString,
response_deserializer=memory__pb2.Response.FromString,
)


class MemoryGraphServicer(object):
Expand All @@ -32,68 +32,93 @@ class MemoryGraphServicer(object):
def Satisfy(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
context.set_details("Method not implemented!")
raise NotImplementedError("Method not implemented!")

def Register(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
context.set_details("Method not implemented!")
raise NotImplementedError("Method not implemented!")


def add_MemoryGraphServicer_to_server(servicer, server):
rpc_method_handlers = {
'Satisfy': grpc.unary_unary_rpc_method_handler(
servicer.Satisfy,
request_deserializer=memory__pb2.SatisfyRequest.FromString,
response_serializer=memory__pb2.SatisfyResponse.SerializeToString,
),
'Register': grpc.unary_unary_rpc_method_handler(
servicer.Register,
request_deserializer=memory__pb2.RegisterRequest.FromString,
response_serializer=memory__pb2.Response.SerializeToString,
),
"Satisfy": grpc.unary_unary_rpc_method_handler(
servicer.Satisfy,
request_deserializer=memory__pb2.SatisfyRequest.FromString,
response_serializer=memory__pb2.SatisfyResponse.SerializeToString,
),
"Register": grpc.unary_unary_rpc_method_handler(
servicer.Register,
request_deserializer=memory__pb2.RegisterRequest.FromString,
response_serializer=memory__pb2.Response.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'service.MemoryGraph', rpc_method_handlers)
"service.MemoryGraph", rpc_method_handlers
)
server.add_generic_rpc_handlers((generic_handler,))


# This class is part of an EXPERIMENTAL API.
# This class is part of an EXPERIMENTAL API.
class MemoryGraph(object):
"""Missing associated documentation comment in .proto file."""

@staticmethod
def Satisfy(request,
def Satisfy(
request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None,
):
return grpc.experimental.unary_unary(
request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/service.MemoryGraph/Satisfy',
"/service.MemoryGraph/Satisfy",
memory__pb2.SatisfyRequest.SerializeToString,
memory__pb2.SatisfyResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
)

@staticmethod
def Register(request,
def Register(
request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None,
):
return grpc.experimental.unary_unary(
request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/service.MemoryGraph/Register',
"/service.MemoryGraph/Register",
memory__pb2.RegisterRequest.SerializeToString,
memory__pb2.Response.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
)
Loading

0 comments on commit 32b41aa

Please sign in to comment.