Skip to content

Commit

Permalink
linting
Browse files Browse the repository at this point in the history
Signed-off-by: vsoch <[email protected]>
  • Loading branch information
vsoch committed Mar 30, 2024
1 parent 749eabe commit deafd56
Show file tree
Hide file tree
Showing 6 changed files with 325 additions and 242 deletions.
4 changes: 1 addition & 3 deletions docs/algorithms.md
Original file line number Diff line number Diff line change
Expand Up @@ -119,7 +119,7 @@ I understand this is likely not perfect for what everyone wants, but I believe i
## Match Algorithms
### Match
### Match
The expliciy "match" type is going to look exactly at the type of a subsystem node, and return true (match) if it matches what the subsystem needs. For example, given this task:
Expand All @@ -146,5 +146,3 @@ We would look for a node of type "shm" in the io subystem that is directly attac
This algorithm speaks for itself. Given a listing of contender clusters (where all clusters have a match) we randomly choose.
[home](/README.md#rainbow-scheduler)
2 changes: 1 addition & 1 deletion plugins/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -3,4 +3,4 @@
- [backends](backends): are for the graph backend used
- [algorithms](algorithms): is the algorithm used to match a subsystem to a slot (loaded by graphs)
- Each graph can choose a different default, if desired
- [selection](selection): is the final cluster selection algorithm (e.g., selecting cluster from a final matched list)
- [selection](selection): is the final cluster selection algorithm (e.g., selecting cluster from a final matched list)
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 deafd56

Please sign in to comment.