# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! """Client and server classes corresponding to protobuf-defined services.""" import grpc from . import node_manager_pb2 as src_dot_ray_dot_protobuf_dot_node__manager__pb2 class NodeManagerServiceStub(object): """Missing associated documentation comment in .proto file.""" def __init__(self, channel): """Constructor. Args: channel: A grpc.Channel. """ self.NotifyGCSRestart = channel.unary_unary( '/ray.rpc.NodeManagerService/NotifyGCSRestart', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.NotifyGCSRestartRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.NotifyGCSRestartReply.FromString, ) self.GetResourceLoad = channel.unary_unary( '/ray.rpc.NodeManagerService/GetResourceLoad', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetResourceLoadRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetResourceLoadReply.FromString, ) self.CancelLeasesWithResourceShapes = channel.unary_unary( '/ray.rpc.NodeManagerService/CancelLeasesWithResourceShapes', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.CancelLeasesWithResourceShapesRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.CancelLeasesWithResourceShapesReply.FromString, ) self.RequestWorkerLease = channel.unary_unary( '/ray.rpc.NodeManagerService/RequestWorkerLease', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.RequestWorkerLeaseRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.RequestWorkerLeaseReply.FromString, ) self.PrestartWorkers = channel.unary_unary( '/ray.rpc.NodeManagerService/PrestartWorkers', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.PrestartWorkersRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.PrestartWorkersReply.FromString, ) self.ReportWorkerBacklog = channel.unary_unary( '/ray.rpc.NodeManagerService/ReportWorkerBacklog', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.ReportWorkerBacklogRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.ReportWorkerBacklogReply.FromString, ) self.ReturnWorkerLease = channel.unary_unary( '/ray.rpc.NodeManagerService/ReturnWorkerLease', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.ReturnWorkerLeaseRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.ReturnWorkerLeaseReply.FromString, ) self.ReleaseUnusedActorWorkers = channel.unary_unary( '/ray.rpc.NodeManagerService/ReleaseUnusedActorWorkers', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.ReleaseUnusedActorWorkersRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.ReleaseUnusedActorWorkersReply.FromString, ) self.ShutdownRaylet = channel.unary_unary( '/ray.rpc.NodeManagerService/ShutdownRaylet', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.ShutdownRayletRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.ShutdownRayletReply.FromString, ) self.DrainRaylet = channel.unary_unary( '/ray.rpc.NodeManagerService/DrainRaylet', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.DrainRayletRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.DrainRayletReply.FromString, ) self.PrepareBundleResources = channel.unary_unary( '/ray.rpc.NodeManagerService/PrepareBundleResources', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.PrepareBundleResourcesRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.PrepareBundleResourcesReply.FromString, ) self.CommitBundleResources = channel.unary_unary( '/ray.rpc.NodeManagerService/CommitBundleResources', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.CommitBundleResourcesRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.CommitBundleResourcesReply.FromString, ) self.CancelResourceReserve = channel.unary_unary( '/ray.rpc.NodeManagerService/CancelResourceReserve', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.CancelResourceReserveRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.CancelResourceReserveReply.FromString, ) self.ResizeLocalResourceInstances = channel.unary_unary( '/ray.rpc.NodeManagerService/ResizeLocalResourceInstances', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.ResizeLocalResourceInstancesRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.ResizeLocalResourceInstancesReply.FromString, ) self.CancelWorkerLease = channel.unary_unary( '/ray.rpc.NodeManagerService/CancelWorkerLease', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.CancelWorkerLeaseRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.CancelWorkerLeaseReply.FromString, ) self.PinObjectIDs = channel.unary_unary( '/ray.rpc.NodeManagerService/PinObjectIDs', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.PinObjectIDsRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.PinObjectIDsReply.FromString, ) self.GetNodeStats = channel.unary_unary( '/ray.rpc.NodeManagerService/GetNodeStats', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetNodeStatsRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetNodeStatsReply.FromString, ) self.GlobalGC = channel.unary_unary( '/ray.rpc.NodeManagerService/GlobalGC', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GlobalGCRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GlobalGCReply.FromString, ) self.FormatGlobalMemoryInfo = channel.unary_unary( '/ray.rpc.NodeManagerService/FormatGlobalMemoryInfo', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.FormatGlobalMemoryInfoRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.FormatGlobalMemoryInfoReply.FromString, ) self.ReleaseUnusedBundles = channel.unary_unary( '/ray.rpc.NodeManagerService/ReleaseUnusedBundles', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.ReleaseUnusedBundlesRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.ReleaseUnusedBundlesReply.FromString, ) self.GetSystemConfig = channel.unary_unary( '/ray.rpc.NodeManagerService/GetSystemConfig', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetSystemConfigRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetSystemConfigReply.FromString, ) self.GetObjectsInfo = channel.unary_unary( '/ray.rpc.NodeManagerService/GetObjectsInfo', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetObjectsInfoRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetObjectsInfoReply.FromString, ) self.GetWorkerFailureCause = channel.unary_unary( '/ray.rpc.NodeManagerService/GetWorkerFailureCause', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetWorkerFailureCauseRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetWorkerFailureCauseReply.FromString, ) self.RegisterMutableObject = channel.unary_unary( '/ray.rpc.NodeManagerService/RegisterMutableObject', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.RegisterMutableObjectRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.RegisterMutableObjectReply.FromString, ) self.PushMutableObject = channel.unary_unary( '/ray.rpc.NodeManagerService/PushMutableObject', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.PushMutableObjectRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.PushMutableObjectReply.FromString, ) self.IsLocalWorkerDead = channel.unary_unary( '/ray.rpc.NodeManagerService/IsLocalWorkerDead', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.IsLocalWorkerDeadRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.IsLocalWorkerDeadReply.FromString, ) self.GetWorkerPIDs = channel.unary_unary( '/ray.rpc.NodeManagerService/GetWorkerPIDs', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetWorkerPIDsRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetWorkerPIDsReply.FromString, ) self.KillLocalActor = channel.unary_unary( '/ray.rpc.NodeManagerService/KillLocalActor', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.KillLocalActorRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.KillLocalActorReply.FromString, ) self.CancelLocalTask = channel.unary_unary( '/ray.rpc.NodeManagerService/CancelLocalTask', request_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.CancelLocalTaskRequest.SerializeToString, response_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.CancelLocalTaskReply.FromString, ) class NodeManagerServiceServicer(object): """Missing associated documentation comment in .proto file.""" def NotifyGCSRestart(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!') def GetResourceLoad(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!') def CancelLeasesWithResourceShapes(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!') def RequestWorkerLease(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!') def PrestartWorkers(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!') def ReportWorkerBacklog(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!') def ReturnWorkerLease(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!') def ReleaseUnusedActorWorkers(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!') def ShutdownRaylet(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!') def DrainRaylet(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!') def PrepareBundleResources(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!') def CommitBundleResources(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!') def CancelResourceReserve(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!') def ResizeLocalResourceInstances(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!') def CancelWorkerLease(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!') def PinObjectIDs(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!') def GetNodeStats(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!') def GlobalGC(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!') def FormatGlobalMemoryInfo(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!') def ReleaseUnusedBundles(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!') def GetSystemConfig(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!') def GetObjectsInfo(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!') def GetWorkerFailureCause(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!') def RegisterMutableObject(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!') def PushMutableObject(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!') def IsLocalWorkerDead(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!') def GetWorkerPIDs(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!') def KillLocalActor(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!') def CancelLocalTask(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!') def add_NodeManagerServiceServicer_to_server(servicer, server): rpc_method_handlers = { 'NotifyGCSRestart': grpc.unary_unary_rpc_method_handler( servicer.NotifyGCSRestart, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.NotifyGCSRestartRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.NotifyGCSRestartReply.SerializeToString, ), 'GetResourceLoad': grpc.unary_unary_rpc_method_handler( servicer.GetResourceLoad, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetResourceLoadRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetResourceLoadReply.SerializeToString, ), 'CancelLeasesWithResourceShapes': grpc.unary_unary_rpc_method_handler( servicer.CancelLeasesWithResourceShapes, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.CancelLeasesWithResourceShapesRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.CancelLeasesWithResourceShapesReply.SerializeToString, ), 'RequestWorkerLease': grpc.unary_unary_rpc_method_handler( servicer.RequestWorkerLease, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.RequestWorkerLeaseRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.RequestWorkerLeaseReply.SerializeToString, ), 'PrestartWorkers': grpc.unary_unary_rpc_method_handler( servicer.PrestartWorkers, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.PrestartWorkersRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.PrestartWorkersReply.SerializeToString, ), 'ReportWorkerBacklog': grpc.unary_unary_rpc_method_handler( servicer.ReportWorkerBacklog, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.ReportWorkerBacklogRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.ReportWorkerBacklogReply.SerializeToString, ), 'ReturnWorkerLease': grpc.unary_unary_rpc_method_handler( servicer.ReturnWorkerLease, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.ReturnWorkerLeaseRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.ReturnWorkerLeaseReply.SerializeToString, ), 'ReleaseUnusedActorWorkers': grpc.unary_unary_rpc_method_handler( servicer.ReleaseUnusedActorWorkers, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.ReleaseUnusedActorWorkersRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.ReleaseUnusedActorWorkersReply.SerializeToString, ), 'ShutdownRaylet': grpc.unary_unary_rpc_method_handler( servicer.ShutdownRaylet, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.ShutdownRayletRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.ShutdownRayletReply.SerializeToString, ), 'DrainRaylet': grpc.unary_unary_rpc_method_handler( servicer.DrainRaylet, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.DrainRayletRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.DrainRayletReply.SerializeToString, ), 'PrepareBundleResources': grpc.unary_unary_rpc_method_handler( servicer.PrepareBundleResources, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.PrepareBundleResourcesRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.PrepareBundleResourcesReply.SerializeToString, ), 'CommitBundleResources': grpc.unary_unary_rpc_method_handler( servicer.CommitBundleResources, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.CommitBundleResourcesRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.CommitBundleResourcesReply.SerializeToString, ), 'CancelResourceReserve': grpc.unary_unary_rpc_method_handler( servicer.CancelResourceReserve, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.CancelResourceReserveRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.CancelResourceReserveReply.SerializeToString, ), 'ResizeLocalResourceInstances': grpc.unary_unary_rpc_method_handler( servicer.ResizeLocalResourceInstances, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.ResizeLocalResourceInstancesRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.ResizeLocalResourceInstancesReply.SerializeToString, ), 'CancelWorkerLease': grpc.unary_unary_rpc_method_handler( servicer.CancelWorkerLease, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.CancelWorkerLeaseRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.CancelWorkerLeaseReply.SerializeToString, ), 'PinObjectIDs': grpc.unary_unary_rpc_method_handler( servicer.PinObjectIDs, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.PinObjectIDsRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.PinObjectIDsReply.SerializeToString, ), 'GetNodeStats': grpc.unary_unary_rpc_method_handler( servicer.GetNodeStats, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetNodeStatsRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetNodeStatsReply.SerializeToString, ), 'GlobalGC': grpc.unary_unary_rpc_method_handler( servicer.GlobalGC, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GlobalGCRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GlobalGCReply.SerializeToString, ), 'FormatGlobalMemoryInfo': grpc.unary_unary_rpc_method_handler( servicer.FormatGlobalMemoryInfo, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.FormatGlobalMemoryInfoRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.FormatGlobalMemoryInfoReply.SerializeToString, ), 'ReleaseUnusedBundles': grpc.unary_unary_rpc_method_handler( servicer.ReleaseUnusedBundles, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.ReleaseUnusedBundlesRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.ReleaseUnusedBundlesReply.SerializeToString, ), 'GetSystemConfig': grpc.unary_unary_rpc_method_handler( servicer.GetSystemConfig, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetSystemConfigRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetSystemConfigReply.SerializeToString, ), 'GetObjectsInfo': grpc.unary_unary_rpc_method_handler( servicer.GetObjectsInfo, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetObjectsInfoRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetObjectsInfoReply.SerializeToString, ), 'GetWorkerFailureCause': grpc.unary_unary_rpc_method_handler( servicer.GetWorkerFailureCause, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetWorkerFailureCauseRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetWorkerFailureCauseReply.SerializeToString, ), 'RegisterMutableObject': grpc.unary_unary_rpc_method_handler( servicer.RegisterMutableObject, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.RegisterMutableObjectRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.RegisterMutableObjectReply.SerializeToString, ), 'PushMutableObject': grpc.unary_unary_rpc_method_handler( servicer.PushMutableObject, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.PushMutableObjectRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.PushMutableObjectReply.SerializeToString, ), 'IsLocalWorkerDead': grpc.unary_unary_rpc_method_handler( servicer.IsLocalWorkerDead, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.IsLocalWorkerDeadRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.IsLocalWorkerDeadReply.SerializeToString, ), 'GetWorkerPIDs': grpc.unary_unary_rpc_method_handler( servicer.GetWorkerPIDs, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetWorkerPIDsRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetWorkerPIDsReply.SerializeToString, ), 'KillLocalActor': grpc.unary_unary_rpc_method_handler( servicer.KillLocalActor, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.KillLocalActorRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.KillLocalActorReply.SerializeToString, ), 'CancelLocalTask': grpc.unary_unary_rpc_method_handler( servicer.CancelLocalTask, request_deserializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.CancelLocalTaskRequest.FromString, response_serializer=src_dot_ray_dot_protobuf_dot_node__manager__pb2.CancelLocalTaskReply.SerializeToString, ), } generic_handler = grpc.method_handlers_generic_handler( 'ray.rpc.NodeManagerService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) # This class is part of an EXPERIMENTAL API. class NodeManagerService(object): """Missing associated documentation comment in .proto file.""" @staticmethod def NotifyGCSRestart(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, '/ray.rpc.NodeManagerService/NotifyGCSRestart', src_dot_ray_dot_protobuf_dot_node__manager__pb2.NotifyGCSRestartRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.NotifyGCSRestartReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def GetResourceLoad(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, '/ray.rpc.NodeManagerService/GetResourceLoad', src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetResourceLoadRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetResourceLoadReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def CancelLeasesWithResourceShapes(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, '/ray.rpc.NodeManagerService/CancelLeasesWithResourceShapes', src_dot_ray_dot_protobuf_dot_node__manager__pb2.CancelLeasesWithResourceShapesRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.CancelLeasesWithResourceShapesReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def RequestWorkerLease(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, '/ray.rpc.NodeManagerService/RequestWorkerLease', src_dot_ray_dot_protobuf_dot_node__manager__pb2.RequestWorkerLeaseRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.RequestWorkerLeaseReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def PrestartWorkers(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, '/ray.rpc.NodeManagerService/PrestartWorkers', src_dot_ray_dot_protobuf_dot_node__manager__pb2.PrestartWorkersRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.PrestartWorkersReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def ReportWorkerBacklog(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, '/ray.rpc.NodeManagerService/ReportWorkerBacklog', src_dot_ray_dot_protobuf_dot_node__manager__pb2.ReportWorkerBacklogRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.ReportWorkerBacklogReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def ReturnWorkerLease(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, '/ray.rpc.NodeManagerService/ReturnWorkerLease', src_dot_ray_dot_protobuf_dot_node__manager__pb2.ReturnWorkerLeaseRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.ReturnWorkerLeaseReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def ReleaseUnusedActorWorkers(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, '/ray.rpc.NodeManagerService/ReleaseUnusedActorWorkers', src_dot_ray_dot_protobuf_dot_node__manager__pb2.ReleaseUnusedActorWorkersRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.ReleaseUnusedActorWorkersReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def ShutdownRaylet(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, '/ray.rpc.NodeManagerService/ShutdownRaylet', src_dot_ray_dot_protobuf_dot_node__manager__pb2.ShutdownRayletRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.ShutdownRayletReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def DrainRaylet(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, '/ray.rpc.NodeManagerService/DrainRaylet', src_dot_ray_dot_protobuf_dot_node__manager__pb2.DrainRayletRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.DrainRayletReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def PrepareBundleResources(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, '/ray.rpc.NodeManagerService/PrepareBundleResources', src_dot_ray_dot_protobuf_dot_node__manager__pb2.PrepareBundleResourcesRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.PrepareBundleResourcesReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def CommitBundleResources(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, '/ray.rpc.NodeManagerService/CommitBundleResources', src_dot_ray_dot_protobuf_dot_node__manager__pb2.CommitBundleResourcesRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.CommitBundleResourcesReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def CancelResourceReserve(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, '/ray.rpc.NodeManagerService/CancelResourceReserve', src_dot_ray_dot_protobuf_dot_node__manager__pb2.CancelResourceReserveRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.CancelResourceReserveReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def ResizeLocalResourceInstances(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, '/ray.rpc.NodeManagerService/ResizeLocalResourceInstances', src_dot_ray_dot_protobuf_dot_node__manager__pb2.ResizeLocalResourceInstancesRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.ResizeLocalResourceInstancesReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def CancelWorkerLease(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, '/ray.rpc.NodeManagerService/CancelWorkerLease', src_dot_ray_dot_protobuf_dot_node__manager__pb2.CancelWorkerLeaseRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.CancelWorkerLeaseReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def PinObjectIDs(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, '/ray.rpc.NodeManagerService/PinObjectIDs', src_dot_ray_dot_protobuf_dot_node__manager__pb2.PinObjectIDsRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.PinObjectIDsReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def GetNodeStats(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, '/ray.rpc.NodeManagerService/GetNodeStats', src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetNodeStatsRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetNodeStatsReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def GlobalGC(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, '/ray.rpc.NodeManagerService/GlobalGC', src_dot_ray_dot_protobuf_dot_node__manager__pb2.GlobalGCRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.GlobalGCReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def FormatGlobalMemoryInfo(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, '/ray.rpc.NodeManagerService/FormatGlobalMemoryInfo', src_dot_ray_dot_protobuf_dot_node__manager__pb2.FormatGlobalMemoryInfoRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.FormatGlobalMemoryInfoReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def ReleaseUnusedBundles(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, '/ray.rpc.NodeManagerService/ReleaseUnusedBundles', src_dot_ray_dot_protobuf_dot_node__manager__pb2.ReleaseUnusedBundlesRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.ReleaseUnusedBundlesReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def GetSystemConfig(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, '/ray.rpc.NodeManagerService/GetSystemConfig', src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetSystemConfigRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetSystemConfigReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def GetObjectsInfo(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, '/ray.rpc.NodeManagerService/GetObjectsInfo', src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetObjectsInfoRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetObjectsInfoReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def GetWorkerFailureCause(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, '/ray.rpc.NodeManagerService/GetWorkerFailureCause', src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetWorkerFailureCauseRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetWorkerFailureCauseReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def RegisterMutableObject(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, '/ray.rpc.NodeManagerService/RegisterMutableObject', src_dot_ray_dot_protobuf_dot_node__manager__pb2.RegisterMutableObjectRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.RegisterMutableObjectReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def PushMutableObject(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, '/ray.rpc.NodeManagerService/PushMutableObject', src_dot_ray_dot_protobuf_dot_node__manager__pb2.PushMutableObjectRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.PushMutableObjectReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def IsLocalWorkerDead(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, '/ray.rpc.NodeManagerService/IsLocalWorkerDead', src_dot_ray_dot_protobuf_dot_node__manager__pb2.IsLocalWorkerDeadRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.IsLocalWorkerDeadReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def GetWorkerPIDs(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, '/ray.rpc.NodeManagerService/GetWorkerPIDs', src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetWorkerPIDsRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.GetWorkerPIDsReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def KillLocalActor(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, '/ray.rpc.NodeManagerService/KillLocalActor', src_dot_ray_dot_protobuf_dot_node__manager__pb2.KillLocalActorRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.KillLocalActorReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) @staticmethod def CancelLocalTask(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, '/ray.rpc.NodeManagerService/CancelLocalTask', src_dot_ray_dot_protobuf_dot_node__manager__pb2.CancelLocalTaskRequest.SerializeToString, src_dot_ray_dot_protobuf_dot_node__manager__pb2.CancelLocalTaskReply.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata)