# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler.  DO NOT EDIT!
# source: src/ray/protobuf/node_manager.proto
"""Generated protocol buffer code."""
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
from google.protobuf import message as _message
from google.protobuf import reflection as _reflection
from google.protobuf import symbol_database as _symbol_database
# @@protoc_insertion_point(imports)

_sym_db = _symbol_database.Default()


from . import common_pb2 as src_dot_ray_dot_protobuf_dot_common__pb2
from . import gcs_pb2 as src_dot_ray_dot_protobuf_dot_gcs__pb2
from . import autoscaler_pb2 as src_dot_ray_dot_protobuf_dot_autoscaler__pb2
from . import runtime_environment_pb2 as src_dot_ray_dot_protobuf_dot_public_dot_runtime__environment__pb2


DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n#src/ray/protobuf/node_manager.proto\x12\x07ray.rpc\x1a\x1dsrc/ray/protobuf/common.proto\x1a\x1asrc/ray/protobuf/gcs.proto\x1a!src/ray/protobuf/autoscaler.proto\x1a\x31src/ray/protobuf/public/runtime_environment.proto\"k\n\x13WorkerBacklogReport\x12\x31\n\nlease_spec\x18\x01 \x01(\x0b\x32\x12.ray.rpc.LeaseSpecR\tleaseSpec\x12!\n\x0c\x62\x61\x63klog_size\x18\x02 \x01(\x03R\x0b\x62\x61\x63klogSize\"\x80\x01\n\x1aReportWorkerBacklogRequest\x12\x1b\n\tworker_id\x18\x01 \x01(\x0cR\x08workerId\x12\x45\n\x0f\x62\x61\x63klog_reports\x18\x02 \x03(\x0b\x32\x1c.ray.rpc.WorkerBacklogReportR\x0e\x62\x61\x63klogReports\"\x1a\n\x18ReportWorkerBacklogReply\"\xdb\x01\n\x19RequestWorkerLeaseRequest\x12\x31\n\nlease_spec\x18\x01 \x01(\x0b\x32\x12.ray.rpc.LeaseSpecR\tleaseSpec\x12!\n\x0c\x62\x61\x63klog_size\x18\x02 \x01(\x03R\x0b\x62\x61\x63klogSize\x12&\n\x0fgrant_or_reject\x18\x03 \x01(\x08R\rgrantOrReject\x12@\n\x1dis_selected_based_on_locality\x18\x04 \x01(\x08R\x19isSelectedBasedOnLocality\"\x81\x06\n\x17RequestWorkerLeaseReply\x12\x37\n\x0eworker_address\x18\x01 \x01(\x0b\x32\x10.ray.rpc.AddressR\rworkerAddress\x12G\n\x17retry_at_raylet_address\x18\x02 \x01(\x0b\x32\x10.ray.rpc.AddressR\x14retryAtRayletAddress\x12\x44\n\x10resource_mapping\x18\x03 \x03(\x0b\x32\x19.ray.rpc.ResourceMapEntryR\x0fresourceMapping\x12\x1a\n\x08\x63\x61nceled\x18\x04 \x01(\x08R\x08\x63\x61nceled\x12\x1d\n\nworker_pid\x18\x06 \x01(\rR\tworkerPid\x12\x1a\n\x08rejected\x18\x07 \x01(\x08R\x08rejected\x12=\n\x0eresources_data\x18\x08 \x01(\x0b\x32\x16.ray.rpc.ResourcesDataR\rresourcesData\x12Y\n\x0c\x66\x61ilure_type\x18\t \x01(\x0e\x32\x36.ray.rpc.RequestWorkerLeaseReply.SchedulingFailureTypeR\x0b\x66\x61ilureType\x12<\n\x1ascheduling_failure_message\x18\n \x01(\tR\x18schedulingFailureMessage\"\xee\x01\n\x15SchedulingFailureType\x12\x0e\n\nNOT_FAILED\x10\x00\x12\x15\n\x11SCHEDULING_FAILED\x10\x01\x12\x30\n,SCHEDULING_CANCELLED_PLACEMENT_GROUP_REMOVED\x10\x02\x12\x31\n-SCHEDULING_CANCELLED_RUNTIME_ENV_SETUP_FAILED\x10\x03\x12!\n\x1dSCHEDULING_CANCELLED_INTENDED\x10\x04\x12&\n\"SCHEDULING_CANCELLED_UNSCHEDULABLE\x10\x05\"\x8b\x02\n\x16PrestartWorkersRequest\x12-\n\x08language\x18\x01 \x01(\x0e\x32\x11.ray.rpc.LanguageR\x08language\x12\x1a\n\x06job_id\x18\x02 \x01(\x0cH\x00R\x05jobId\x88\x01\x01\x12\x41\n\x10runtime_env_info\x18\x03 \x01(\x0b\x32\x17.ray.rpc.RuntimeEnvInfoR\x0eruntimeEnvInfo\x12\x37\n\x18keep_alive_duration_secs\x18\x04 \x01(\x04R\x15keepAliveDurationSecs\x12\x1f\n\x0bnum_workers\x18\x05 \x01(\x04R\nnumWorkersB\t\n\x07_job_id\"\x16\n\x14PrestartWorkersReply\"S\n\x1dPrepareBundleResourcesRequest\x12\x32\n\x0c\x62undle_specs\x18\x01 \x03(\x0b\x32\x0f.ray.rpc.BundleR\x0b\x62undleSpecs\"7\n\x1bPrepareBundleResourcesReply\x12\x18\n\x07success\x18\x01 \x01(\x08R\x07success\"R\n\x1c\x43ommitBundleResourcesRequest\x12\x32\n\x0c\x62undle_specs\x18\x01 \x03(\x0b\x32\x0f.ray.rpc.BundleR\x0b\x62undleSpecs\"\x1c\n\x1a\x43ommitBundleResourcesReply\"P\n\x1c\x43\x61ncelResourceReserveRequest\x12\x30\n\x0b\x62undle_spec\x18\x01 \x01(\x0b\x32\x0f.ray.rpc.BundleR\nbundleSpec\"\x1c\n\x1a\x43\x61ncelResourceReserveReply\"\xbe\x01\n#ResizeLocalResourceInstancesRequest\x12Y\n\tresources\x18\x01 \x03(\x0b\x32;.ray.rpc.ResizeLocalResourceInstancesRequest.ResourcesEntryR\tresources\x1a<\n\x0eResourcesEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\x01R\x05value:\x02\x38\x01\"\xcf\x01\n!ResizeLocalResourceInstancesReply\x12g\n\x0ftotal_resources\x18\x01 \x03(\x0b\x32>.ray.rpc.ResizeLocalResourceInstancesReply.TotalResourcesEntryR\x0etotalResources\x1a\x41\n\x13TotalResourcesEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\x01R\x05value:\x02\x38\x01\"\xef\x01\n\x18ReturnWorkerLeaseRequest\x12\x1f\n\x0bworker_port\x18\x01 \x01(\x05R\nworkerPort\x12\x19\n\x08lease_id\x18\x02 \x01(\x0cR\x07leaseId\x12+\n\x11\x64isconnect_worker\x18\x03 \x01(\x08R\x10\x64isconnectWorker\x12%\n\x0eworker_exiting\x18\x04 \x01(\x08R\rworkerExiting\x12\x43\n\x1e\x64isconnect_worker_error_detail\x18\x05 \x01(\tR\x1b\x64isconnectWorkerErrorDetail\"\x18\n\x16ReturnWorkerLeaseReply\"M\n ReleaseUnusedActorWorkersRequest\x12)\n\x11worker_ids_in_use\x18\x01 \x03(\x0cR\x0eworkerIdsInUse\" \n\x1eReleaseUnusedActorWorkersReply\"3\n\x15ShutdownRayletRequest\x12\x1a\n\x08graceful\x18\x01 \x01(\x08R\x08graceful\"\x15\n\x13ShutdownRayletReply\"5\n\x18\x43\x61ncelWorkerLeaseRequest\x12\x19\n\x08lease_id\x18\x01 \x01(\x0cR\x07leaseId\"2\n\x16\x43\x61ncelWorkerLeaseReply\x12\x18\n\x07success\x18\x01 \x01(\x08R\x07success\"\xa4\x01\n\x13PinObjectIDsRequest\x12\x35\n\rowner_address\x18\x01 \x01(\x0b\x32\x10.ray.rpc.AddressR\x0cownerAddress\x12\x1d\n\nobject_ids\x18\x02 \x03(\x0cR\tobjectIds\x12&\n\x0cgenerator_id\x18\x03 \x01(\x0cH\x00R\x0bgeneratorId\x88\x01\x01\x42\x0f\n\r_generator_id\"1\n\x11PinObjectIDsReply\x12\x1c\n\tsuccesses\x18\x01 \x03(\x08R\tsuccesses\"E\n\x13GetNodeStatsRequest\x12.\n\x13include_memory_info\x18\x01 \x01(\x08R\x11includeMemoryInfo\"\xcb\x06\n\x10ObjectStoreStats\x12+\n\x12spill_time_total_s\x18\x01 \x01(\x01R\x0fspillTimeTotalS\x12.\n\x13spilled_bytes_total\x18\x02 \x01(\x03R\x11spilledBytesTotal\x12\x32\n\x15spilled_objects_total\x18\x03 \x01(\x03R\x13spilledObjectsTotal\x12/\n\x14restore_time_total_s\x18\x04 \x01(\x01R\x11restoreTimeTotalS\x12\x30\n\x14restored_bytes_total\x18\x05 \x01(\x03R\x12restoredBytesTotal\x12\x34\n\x16restored_objects_total\x18\x06 \x01(\x03R\x14restoredObjectsTotal\x12\x35\n\x17object_store_bytes_used\x18\x07 \x01(\x03R\x14objectStoreBytesUsed\x12\x37\n\x18object_store_bytes_avail\x18\x08 \x01(\x03R\x15objectStoreBytesAvail\x12\x44\n\x1fobject_store_bytes_primary_copy\x18\t \x01(\x03R\x1bobjectStoreBytesPrimaryCopy\x12=\n\x1bobject_store_bytes_fallback\x18\n \x01(\x03R\x18objectStoreBytesFallback\x12*\n\x11num_local_objects\x18\x0b \x01(\x03R\x0fnumLocalObjects\x12.\n\x13object_pulls_queued\x18\x0c \x01(\x08R\x11objectPullsQueued\x12\x44\n\x1fnum_object_store_primary_copies\x18\r \x01(\x03R\x1bnumObjectStorePrimaryCopies\x12<\n\x1a\x63umulative_created_objects\x18\x0e \x01(\x03R\x18\x63umulativeCreatedObjects\x12\x38\n\x18\x63umulative_created_bytes\x18\x0f \x01(\x03R\x16\x63umulativeCreatedBytes\"\xb8\x01\n\x11GetNodeStatsReply\x12\x46\n\x12\x63ore_workers_stats\x18\x01 \x03(\x0b\x32\x18.ray.rpc.CoreWorkerStatsR\x10\x63oreWorkersStats\x12\x1f\n\x0bnum_workers\x18\x03 \x01(\rR\nnumWorkers\x12:\n\x0bstore_stats\x18\x06 \x01(\x0b\x32\x19.ray.rpc.ObjectStoreStatsR\nstoreStats\"\x11\n\x0fGlobalGCRequest\"\x0f\n\rGlobalGCReply\"O\n\x1d\x46ormatGlobalMemoryInfoRequest\x12.\n\x13include_memory_info\x18\x01 \x01(\x08R\x11includeMemoryInfo\"\x80\x01\n\x1b\x46ormatGlobalMemoryInfoReply\x12%\n\x0ememory_summary\x18\x01 \x01(\tR\rmemorySummary\x12:\n\x0bstore_stats\x18\x02 \x01(\x0b\x32\x19.ray.rpc.ObjectStoreStatsR\nstoreStats\"T\n\x1bReleaseUnusedBundlesRequest\x12\x35\n\x0e\x62undles_in_use\x18\x01 \x03(\x0b\x32\x0f.ray.rpc.BundleR\x0c\x62undlesInUse\"\x1b\n\x19ReleaseUnusedBundlesReply\"\x18\n\x16GetSystemConfigRequest\";\n\x14GetSystemConfigReply\x12#\n\rsystem_config\x18\x01 \x01(\tR\x0csystemConfig\"<\n\x15GetObjectsInfoRequest\x12\x19\n\x05limit\x18\x01 \x01(\x03H\x00R\x05limit\x88\x01\x01\x42\x08\n\x06_limit\"s\n\x13GetObjectsInfoReply\x12\x46\n\x12\x63ore_workers_stats\x18\x01 \x03(\x0b\x32\x18.ray.rpc.CoreWorkerStatsR\x10\x63oreWorkersStats\x12\x14\n\x05total\x18\x02 \x01(\x03R\x05total\"\x18\n\x16GetResourceLoadRequest\"L\n\x14GetResourceLoadReply\x12\x34\n\tresources\x18\x01 \x01(\x0b\x32\x16.ray.rpc.ResourcesDataR\tresources\"\xda\x02\n%CancelLeasesWithResourceShapesRequest\x12\x65\n\x0fresource_shapes\x18\x01 \x03(\x0b\x32<.ray.rpc.CancelLeasesWithResourceShapesRequest.ResourceShapeR\x0eresourceShapes\x1a\xc9\x01\n\rResourceShape\x12v\n\x0eresource_shape\x18\x01 \x03(\x0b\x32O.ray.rpc.CancelLeasesWithResourceShapesRequest.ResourceShape.ResourceShapeEntryR\rresourceShape\x1a@\n\x12ResourceShapeEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\x01R\x05value:\x02\x38\x01\"%\n#CancelLeasesWithResourceShapesReply\"\x19\n\x17NotifyGCSRestartRequest\"\x17\n\x15NotifyGCSRestartReply\"9\n\x1cGetWorkerFailureCauseRequest\x12\x19\n\x08lease_id\x18\x01 \x01(\x0cR\x07leaseId\"\xa3\x01\n\x1aGetWorkerFailureCauseReply\x12?\n\rfailure_cause\x18\x01 \x01(\x0b\x32\x15.ray.rpc.RayErrorInfoH\x00R\x0c\x66\x61ilureCause\x88\x01\x01\x12\x32\n\x15\x66\x61il_task_immediately\x18\x02 \x01(\x08R\x13\x66\x61ilTaskImmediatelyB\x10\n\x0e_failure_cause\"\xac\x01\n\x12\x44rainRayletRequest\x12;\n\x06reason\x18\x01 \x01(\x0e\x32#.ray.rpc.autoscaler.DrainNodeReasonR\x06reason\x12%\n\x0ereason_message\x18\x02 \x01(\tR\rreasonMessage\x12\x32\n\x15\x64\x65\x61\x64line_timestamp_ms\x18\x03 \x01(\x03R\x13\x64\x65\x61\x64lineTimestampMs\"m\n\x10\x44rainRayletReply\x12\x1f\n\x0bis_accepted\x18\x01 \x01(\x08R\nisAccepted\x12\x38\n\x18rejection_reason_message\x18\x02 \x01(\tR\x16rejectionReasonMessage\"\x93\x01\n\x1cRegisterMutableObjectRequest\x12(\n\x10writer_object_id\x18\x01 \x01(\x0cR\x0ewriterObjectId\x12\x1f\n\x0bnum_readers\x18\x02 \x01(\x03R\nnumReaders\x12(\n\x10reader_object_id\x18\x03 \x01(\x0cR\x0ereaderObjectId\"\x1c\n\x1aRegisterMutableObjectReply\"\x83\x02\n\x18PushMutableObjectRequest\x12(\n\x10writer_object_id\x18\x01 \x01(\x0cR\x0ewriterObjectId\x12&\n\x0ftotal_data_size\x18\x02 \x01(\x04R\rtotalDataSize\x12.\n\x13total_metadata_size\x18\x03 \x01(\x04R\x11totalMetadataSize\x12\x16\n\x06offset\x18\x04 \x01(\x04R\x06offset\x12\x1d\n\nchunk_size\x18\x05 \x01(\x04R\tchunkSize\x12\x12\n\x04\x64\x61ta\x18\x06 \x01(\x0cR\x04\x64\x61ta\x12\x1a\n\x08metadata\x18\x07 \x01(\x0cR\x08metadata\",\n\x16PushMutableObjectReply\x12\x12\n\x04\x64one\x18\x01 \x01(\x08R\x04\x64one\"7\n\x18IsLocalWorkerDeadRequest\x12\x1b\n\tworker_id\x18\x01 \x01(\x0cR\x08workerId\"1\n\x16IsLocalWorkerDeadReply\x12\x17\n\x07is_dead\x18\x01 \x01(\x08R\x06isDead\"\x16\n\x14GetWorkerPIDsRequest\"(\n\x12GetWorkerPIDsReply\x12\x12\n\x04pids\x18\x01 \x03(\x05R\x04pids\"\xba\x01\n\x15KillLocalActorRequest\x12*\n\x11intended_actor_id\x18\x01 \x01(\x0cR\x0fintendedActorId\x12\x1b\n\tworker_id\x18\x02 \x01(\x0cR\x08workerId\x12\x1d\n\nforce_kill\x18\x03 \x01(\x08R\tforceKill\x12\x39\n\x0b\x64\x65\x61th_cause\x18\x04 \x01(\x0b\x32\x18.ray.rpc.ActorDeathCauseR\ndeathCause\"\x15\n\x13KillLocalActorReply\"\xd7\x01\n\x16\x43\x61ncelLocalTaskRequest\x12(\n\x10intended_task_id\x18\x01 \x01(\x0cR\x0eintendedTaskId\x12\x1d\n\nforce_kill\x18\x02 \x01(\x08R\tforceKill\x12\x1c\n\trecursive\x18\x03 \x01(\x08R\trecursive\x12(\n\x10\x63\x61ller_worker_id\x18\x04 \x01(\x0cR\x0e\x63\x61llerWorkerId\x12,\n\x12\x65xecutor_worker_id\x18\x05 \x01(\x0cR\x10\x65xecutorWorkerId\"y\n\x14\x43\x61ncelLocalTaskReply\x12\x34\n\x16requested_task_running\x18\x01 \x01(\x08R\x14requestedTaskRunning\x12+\n\x11\x61ttempt_succeeded\x18\x02 \x01(\x08R\x10\x61ttemptSucceeded2\xdc\x14\n\x12NodeManagerService\x12T\n\x10NotifyGCSRestart\x12 .ray.rpc.NotifyGCSRestartRequest\x1a\x1e.ray.rpc.NotifyGCSRestartReply\x12Q\n\x0fGetResourceLoad\x12\x1f.ray.rpc.GetResourceLoadRequest\x1a\x1d.ray.rpc.GetResourceLoadReply\x12~\n\x1e\x43\x61ncelLeasesWithResourceShapes\x12..ray.rpc.CancelLeasesWithResourceShapesRequest\x1a,.ray.rpc.CancelLeasesWithResourceShapesReply\x12Z\n\x12RequestWorkerLease\x12\".ray.rpc.RequestWorkerLeaseRequest\x1a .ray.rpc.RequestWorkerLeaseReply\x12Q\n\x0fPrestartWorkers\x12\x1f.ray.rpc.PrestartWorkersRequest\x1a\x1d.ray.rpc.PrestartWorkersReply\x12]\n\x13ReportWorkerBacklog\x12#.ray.rpc.ReportWorkerBacklogRequest\x1a!.ray.rpc.ReportWorkerBacklogReply\x12W\n\x11ReturnWorkerLease\x12!.ray.rpc.ReturnWorkerLeaseRequest\x1a\x1f.ray.rpc.ReturnWorkerLeaseReply\x12o\n\x19ReleaseUnusedActorWorkers\x12).ray.rpc.ReleaseUnusedActorWorkersRequest\x1a\'.ray.rpc.ReleaseUnusedActorWorkersReply\x12N\n\x0eShutdownRaylet\x12\x1e.ray.rpc.ShutdownRayletRequest\x1a\x1c.ray.rpc.ShutdownRayletReply\x12\x45\n\x0b\x44rainRaylet\x12\x1b.ray.rpc.DrainRayletRequest\x1a\x19.ray.rpc.DrainRayletReply\x12\x66\n\x16PrepareBundleResources\x12&.ray.rpc.PrepareBundleResourcesRequest\x1a$.ray.rpc.PrepareBundleResourcesReply\x12\x63\n\x15\x43ommitBundleResources\x12%.ray.rpc.CommitBundleResourcesRequest\x1a#.ray.rpc.CommitBundleResourcesReply\x12\x63\n\x15\x43\x61ncelResourceReserve\x12%.ray.rpc.CancelResourceReserveRequest\x1a#.ray.rpc.CancelResourceReserveReply\x12x\n\x1cResizeLocalResourceInstances\x12,.ray.rpc.ResizeLocalResourceInstancesRequest\x1a*.ray.rpc.ResizeLocalResourceInstancesReply\x12W\n\x11\x43\x61ncelWorkerLease\x12!.ray.rpc.CancelWorkerLeaseRequest\x1a\x1f.ray.rpc.CancelWorkerLeaseReply\x12H\n\x0cPinObjectIDs\x12\x1c.ray.rpc.PinObjectIDsRequest\x1a\x1a.ray.rpc.PinObjectIDsReply\x12H\n\x0cGetNodeStats\x12\x1c.ray.rpc.GetNodeStatsRequest\x1a\x1a.ray.rpc.GetNodeStatsReply\x12<\n\x08GlobalGC\x12\x18.ray.rpc.GlobalGCRequest\x1a\x16.ray.rpc.GlobalGCReply\x12\x66\n\x16\x46ormatGlobalMemoryInfo\x12&.ray.rpc.FormatGlobalMemoryInfoRequest\x1a$.ray.rpc.FormatGlobalMemoryInfoReply\x12`\n\x14ReleaseUnusedBundles\x12$.ray.rpc.ReleaseUnusedBundlesRequest\x1a\".ray.rpc.ReleaseUnusedBundlesReply\x12Q\n\x0fGetSystemConfig\x12\x1f.ray.rpc.GetSystemConfigRequest\x1a\x1d.ray.rpc.GetSystemConfigReply\x12N\n\x0eGetObjectsInfo\x12\x1e.ray.rpc.GetObjectsInfoRequest\x1a\x1c.ray.rpc.GetObjectsInfoReply\x12\x63\n\x15GetWorkerFailureCause\x12%.ray.rpc.GetWorkerFailureCauseRequest\x1a#.ray.rpc.GetWorkerFailureCauseReply\x12\x63\n\x15RegisterMutableObject\x12%.ray.rpc.RegisterMutableObjectRequest\x1a#.ray.rpc.RegisterMutableObjectReply\x12W\n\x11PushMutableObject\x12!.ray.rpc.PushMutableObjectRequest\x1a\x1f.ray.rpc.PushMutableObjectReply\x12W\n\x11IsLocalWorkerDead\x12!.ray.rpc.IsLocalWorkerDeadRequest\x1a\x1f.ray.rpc.IsLocalWorkerDeadReply\x12K\n\rGetWorkerPIDs\x12\x1d.ray.rpc.GetWorkerPIDsRequest\x1a\x1b.ray.rpc.GetWorkerPIDsReply\x12N\n\x0eKillLocalActor\x12\x1e.ray.rpc.KillLocalActorRequest\x1a\x1c.ray.rpc.KillLocalActorReply\x12Q\n\x0f\x43\x61ncelLocalTask\x12\x1f.ray.rpc.CancelLocalTaskRequest\x1a\x1d.ray.rpc.CancelLocalTaskReplyb\x06proto3')



_WORKERBACKLOGREPORT = DESCRIPTOR.message_types_by_name['WorkerBacklogReport']
_REPORTWORKERBACKLOGREQUEST = DESCRIPTOR.message_types_by_name['ReportWorkerBacklogRequest']
_REPORTWORKERBACKLOGREPLY = DESCRIPTOR.message_types_by_name['ReportWorkerBacklogReply']
_REQUESTWORKERLEASEREQUEST = DESCRIPTOR.message_types_by_name['RequestWorkerLeaseRequest']
_REQUESTWORKERLEASEREPLY = DESCRIPTOR.message_types_by_name['RequestWorkerLeaseReply']
_PRESTARTWORKERSREQUEST = DESCRIPTOR.message_types_by_name['PrestartWorkersRequest']
_PRESTARTWORKERSREPLY = DESCRIPTOR.message_types_by_name['PrestartWorkersReply']
_PREPAREBUNDLERESOURCESREQUEST = DESCRIPTOR.message_types_by_name['PrepareBundleResourcesRequest']
_PREPAREBUNDLERESOURCESREPLY = DESCRIPTOR.message_types_by_name['PrepareBundleResourcesReply']
_COMMITBUNDLERESOURCESREQUEST = DESCRIPTOR.message_types_by_name['CommitBundleResourcesRequest']
_COMMITBUNDLERESOURCESREPLY = DESCRIPTOR.message_types_by_name['CommitBundleResourcesReply']
_CANCELRESOURCERESERVEREQUEST = DESCRIPTOR.message_types_by_name['CancelResourceReserveRequest']
_CANCELRESOURCERESERVEREPLY = DESCRIPTOR.message_types_by_name['CancelResourceReserveReply']
_RESIZELOCALRESOURCEINSTANCESREQUEST = DESCRIPTOR.message_types_by_name['ResizeLocalResourceInstancesRequest']
_RESIZELOCALRESOURCEINSTANCESREQUEST_RESOURCESENTRY = _RESIZELOCALRESOURCEINSTANCESREQUEST.nested_types_by_name['ResourcesEntry']
_RESIZELOCALRESOURCEINSTANCESREPLY = DESCRIPTOR.message_types_by_name['ResizeLocalResourceInstancesReply']
_RESIZELOCALRESOURCEINSTANCESREPLY_TOTALRESOURCESENTRY = _RESIZELOCALRESOURCEINSTANCESREPLY.nested_types_by_name['TotalResourcesEntry']
_RETURNWORKERLEASEREQUEST = DESCRIPTOR.message_types_by_name['ReturnWorkerLeaseRequest']
_RETURNWORKERLEASEREPLY = DESCRIPTOR.message_types_by_name['ReturnWorkerLeaseReply']
_RELEASEUNUSEDACTORWORKERSREQUEST = DESCRIPTOR.message_types_by_name['ReleaseUnusedActorWorkersRequest']
_RELEASEUNUSEDACTORWORKERSREPLY = DESCRIPTOR.message_types_by_name['ReleaseUnusedActorWorkersReply']
_SHUTDOWNRAYLETREQUEST = DESCRIPTOR.message_types_by_name['ShutdownRayletRequest']
_SHUTDOWNRAYLETREPLY = DESCRIPTOR.message_types_by_name['ShutdownRayletReply']
_CANCELWORKERLEASEREQUEST = DESCRIPTOR.message_types_by_name['CancelWorkerLeaseRequest']
_CANCELWORKERLEASEREPLY = DESCRIPTOR.message_types_by_name['CancelWorkerLeaseReply']
_PINOBJECTIDSREQUEST = DESCRIPTOR.message_types_by_name['PinObjectIDsRequest']
_PINOBJECTIDSREPLY = DESCRIPTOR.message_types_by_name['PinObjectIDsReply']
_GETNODESTATSREQUEST = DESCRIPTOR.message_types_by_name['GetNodeStatsRequest']
_OBJECTSTORESTATS = DESCRIPTOR.message_types_by_name['ObjectStoreStats']
_GETNODESTATSREPLY = DESCRIPTOR.message_types_by_name['GetNodeStatsReply']
_GLOBALGCREQUEST = DESCRIPTOR.message_types_by_name['GlobalGCRequest']
_GLOBALGCREPLY = DESCRIPTOR.message_types_by_name['GlobalGCReply']
_FORMATGLOBALMEMORYINFOREQUEST = DESCRIPTOR.message_types_by_name['FormatGlobalMemoryInfoRequest']
_FORMATGLOBALMEMORYINFOREPLY = DESCRIPTOR.message_types_by_name['FormatGlobalMemoryInfoReply']
_RELEASEUNUSEDBUNDLESREQUEST = DESCRIPTOR.message_types_by_name['ReleaseUnusedBundlesRequest']
_RELEASEUNUSEDBUNDLESREPLY = DESCRIPTOR.message_types_by_name['ReleaseUnusedBundlesReply']
_GETSYSTEMCONFIGREQUEST = DESCRIPTOR.message_types_by_name['GetSystemConfigRequest']
_GETSYSTEMCONFIGREPLY = DESCRIPTOR.message_types_by_name['GetSystemConfigReply']
_GETOBJECTSINFOREQUEST = DESCRIPTOR.message_types_by_name['GetObjectsInfoRequest']
_GETOBJECTSINFOREPLY = DESCRIPTOR.message_types_by_name['GetObjectsInfoReply']
_GETRESOURCELOADREQUEST = DESCRIPTOR.message_types_by_name['GetResourceLoadRequest']
_GETRESOURCELOADREPLY = DESCRIPTOR.message_types_by_name['GetResourceLoadReply']
_CANCELLEASESWITHRESOURCESHAPESREQUEST = DESCRIPTOR.message_types_by_name['CancelLeasesWithResourceShapesRequest']
_CANCELLEASESWITHRESOURCESHAPESREQUEST_RESOURCESHAPE = _CANCELLEASESWITHRESOURCESHAPESREQUEST.nested_types_by_name['ResourceShape']
_CANCELLEASESWITHRESOURCESHAPESREQUEST_RESOURCESHAPE_RESOURCESHAPEENTRY = _CANCELLEASESWITHRESOURCESHAPESREQUEST_RESOURCESHAPE.nested_types_by_name['ResourceShapeEntry']
_CANCELLEASESWITHRESOURCESHAPESREPLY = DESCRIPTOR.message_types_by_name['CancelLeasesWithResourceShapesReply']
_NOTIFYGCSRESTARTREQUEST = DESCRIPTOR.message_types_by_name['NotifyGCSRestartRequest']
_NOTIFYGCSRESTARTREPLY = DESCRIPTOR.message_types_by_name['NotifyGCSRestartReply']
_GETWORKERFAILURECAUSEREQUEST = DESCRIPTOR.message_types_by_name['GetWorkerFailureCauseRequest']
_GETWORKERFAILURECAUSEREPLY = DESCRIPTOR.message_types_by_name['GetWorkerFailureCauseReply']
_DRAINRAYLETREQUEST = DESCRIPTOR.message_types_by_name['DrainRayletRequest']
_DRAINRAYLETREPLY = DESCRIPTOR.message_types_by_name['DrainRayletReply']
_REGISTERMUTABLEOBJECTREQUEST = DESCRIPTOR.message_types_by_name['RegisterMutableObjectRequest']
_REGISTERMUTABLEOBJECTREPLY = DESCRIPTOR.message_types_by_name['RegisterMutableObjectReply']
_PUSHMUTABLEOBJECTREQUEST = DESCRIPTOR.message_types_by_name['PushMutableObjectRequest']
_PUSHMUTABLEOBJECTREPLY = DESCRIPTOR.message_types_by_name['PushMutableObjectReply']
_ISLOCALWORKERDEADREQUEST = DESCRIPTOR.message_types_by_name['IsLocalWorkerDeadRequest']
_ISLOCALWORKERDEADREPLY = DESCRIPTOR.message_types_by_name['IsLocalWorkerDeadReply']
_GETWORKERPIDSREQUEST = DESCRIPTOR.message_types_by_name['GetWorkerPIDsRequest']
_GETWORKERPIDSREPLY = DESCRIPTOR.message_types_by_name['GetWorkerPIDsReply']
_KILLLOCALACTORREQUEST = DESCRIPTOR.message_types_by_name['KillLocalActorRequest']
_KILLLOCALACTORREPLY = DESCRIPTOR.message_types_by_name['KillLocalActorReply']
_CANCELLOCALTASKREQUEST = DESCRIPTOR.message_types_by_name['CancelLocalTaskRequest']
_CANCELLOCALTASKREPLY = DESCRIPTOR.message_types_by_name['CancelLocalTaskReply']
_REQUESTWORKERLEASEREPLY_SCHEDULINGFAILURETYPE = _REQUESTWORKERLEASEREPLY.enum_types_by_name['SchedulingFailureType']
WorkerBacklogReport = _reflection.GeneratedProtocolMessageType('WorkerBacklogReport', (_message.Message,), {
  'DESCRIPTOR' : _WORKERBACKLOGREPORT,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.WorkerBacklogReport)
  })
_sym_db.RegisterMessage(WorkerBacklogReport)

ReportWorkerBacklogRequest = _reflection.GeneratedProtocolMessageType('ReportWorkerBacklogRequest', (_message.Message,), {
  'DESCRIPTOR' : _REPORTWORKERBACKLOGREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.ReportWorkerBacklogRequest)
  })
_sym_db.RegisterMessage(ReportWorkerBacklogRequest)

ReportWorkerBacklogReply = _reflection.GeneratedProtocolMessageType('ReportWorkerBacklogReply', (_message.Message,), {
  'DESCRIPTOR' : _REPORTWORKERBACKLOGREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.ReportWorkerBacklogReply)
  })
_sym_db.RegisterMessage(ReportWorkerBacklogReply)

RequestWorkerLeaseRequest = _reflection.GeneratedProtocolMessageType('RequestWorkerLeaseRequest', (_message.Message,), {
  'DESCRIPTOR' : _REQUESTWORKERLEASEREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.RequestWorkerLeaseRequest)
  })
_sym_db.RegisterMessage(RequestWorkerLeaseRequest)

RequestWorkerLeaseReply = _reflection.GeneratedProtocolMessageType('RequestWorkerLeaseReply', (_message.Message,), {
  'DESCRIPTOR' : _REQUESTWORKERLEASEREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.RequestWorkerLeaseReply)
  })
_sym_db.RegisterMessage(RequestWorkerLeaseReply)

PrestartWorkersRequest = _reflection.GeneratedProtocolMessageType('PrestartWorkersRequest', (_message.Message,), {
  'DESCRIPTOR' : _PRESTARTWORKERSREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.PrestartWorkersRequest)
  })
_sym_db.RegisterMessage(PrestartWorkersRequest)

PrestartWorkersReply = _reflection.GeneratedProtocolMessageType('PrestartWorkersReply', (_message.Message,), {
  'DESCRIPTOR' : _PRESTARTWORKERSREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.PrestartWorkersReply)
  })
_sym_db.RegisterMessage(PrestartWorkersReply)

PrepareBundleResourcesRequest = _reflection.GeneratedProtocolMessageType('PrepareBundleResourcesRequest', (_message.Message,), {
  'DESCRIPTOR' : _PREPAREBUNDLERESOURCESREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.PrepareBundleResourcesRequest)
  })
_sym_db.RegisterMessage(PrepareBundleResourcesRequest)

PrepareBundleResourcesReply = _reflection.GeneratedProtocolMessageType('PrepareBundleResourcesReply', (_message.Message,), {
  'DESCRIPTOR' : _PREPAREBUNDLERESOURCESREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.PrepareBundleResourcesReply)
  })
_sym_db.RegisterMessage(PrepareBundleResourcesReply)

CommitBundleResourcesRequest = _reflection.GeneratedProtocolMessageType('CommitBundleResourcesRequest', (_message.Message,), {
  'DESCRIPTOR' : _COMMITBUNDLERESOURCESREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.CommitBundleResourcesRequest)
  })
_sym_db.RegisterMessage(CommitBundleResourcesRequest)

CommitBundleResourcesReply = _reflection.GeneratedProtocolMessageType('CommitBundleResourcesReply', (_message.Message,), {
  'DESCRIPTOR' : _COMMITBUNDLERESOURCESREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.CommitBundleResourcesReply)
  })
_sym_db.RegisterMessage(CommitBundleResourcesReply)

CancelResourceReserveRequest = _reflection.GeneratedProtocolMessageType('CancelResourceReserveRequest', (_message.Message,), {
  'DESCRIPTOR' : _CANCELRESOURCERESERVEREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.CancelResourceReserveRequest)
  })
_sym_db.RegisterMessage(CancelResourceReserveRequest)

CancelResourceReserveReply = _reflection.GeneratedProtocolMessageType('CancelResourceReserveReply', (_message.Message,), {
  'DESCRIPTOR' : _CANCELRESOURCERESERVEREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.CancelResourceReserveReply)
  })
_sym_db.RegisterMessage(CancelResourceReserveReply)

ResizeLocalResourceInstancesRequest = _reflection.GeneratedProtocolMessageType('ResizeLocalResourceInstancesRequest', (_message.Message,), {

  'ResourcesEntry' : _reflection.GeneratedProtocolMessageType('ResourcesEntry', (_message.Message,), {
    'DESCRIPTOR' : _RESIZELOCALRESOURCEINSTANCESREQUEST_RESOURCESENTRY,
    '__module__' : 'src.ray.protobuf.node_manager_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.ResizeLocalResourceInstancesRequest.ResourcesEntry)
    })
  ,
  'DESCRIPTOR' : _RESIZELOCALRESOURCEINSTANCESREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.ResizeLocalResourceInstancesRequest)
  })
_sym_db.RegisterMessage(ResizeLocalResourceInstancesRequest)
_sym_db.RegisterMessage(ResizeLocalResourceInstancesRequest.ResourcesEntry)

ResizeLocalResourceInstancesReply = _reflection.GeneratedProtocolMessageType('ResizeLocalResourceInstancesReply', (_message.Message,), {

  'TotalResourcesEntry' : _reflection.GeneratedProtocolMessageType('TotalResourcesEntry', (_message.Message,), {
    'DESCRIPTOR' : _RESIZELOCALRESOURCEINSTANCESREPLY_TOTALRESOURCESENTRY,
    '__module__' : 'src.ray.protobuf.node_manager_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.ResizeLocalResourceInstancesReply.TotalResourcesEntry)
    })
  ,
  'DESCRIPTOR' : _RESIZELOCALRESOURCEINSTANCESREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.ResizeLocalResourceInstancesReply)
  })
_sym_db.RegisterMessage(ResizeLocalResourceInstancesReply)
_sym_db.RegisterMessage(ResizeLocalResourceInstancesReply.TotalResourcesEntry)

ReturnWorkerLeaseRequest = _reflection.GeneratedProtocolMessageType('ReturnWorkerLeaseRequest', (_message.Message,), {
  'DESCRIPTOR' : _RETURNWORKERLEASEREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.ReturnWorkerLeaseRequest)
  })
_sym_db.RegisterMessage(ReturnWorkerLeaseRequest)

ReturnWorkerLeaseReply = _reflection.GeneratedProtocolMessageType('ReturnWorkerLeaseReply', (_message.Message,), {
  'DESCRIPTOR' : _RETURNWORKERLEASEREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.ReturnWorkerLeaseReply)
  })
_sym_db.RegisterMessage(ReturnWorkerLeaseReply)

ReleaseUnusedActorWorkersRequest = _reflection.GeneratedProtocolMessageType('ReleaseUnusedActorWorkersRequest', (_message.Message,), {
  'DESCRIPTOR' : _RELEASEUNUSEDACTORWORKERSREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.ReleaseUnusedActorWorkersRequest)
  })
_sym_db.RegisterMessage(ReleaseUnusedActorWorkersRequest)

ReleaseUnusedActorWorkersReply = _reflection.GeneratedProtocolMessageType('ReleaseUnusedActorWorkersReply', (_message.Message,), {
  'DESCRIPTOR' : _RELEASEUNUSEDACTORWORKERSREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.ReleaseUnusedActorWorkersReply)
  })
_sym_db.RegisterMessage(ReleaseUnusedActorWorkersReply)

ShutdownRayletRequest = _reflection.GeneratedProtocolMessageType('ShutdownRayletRequest', (_message.Message,), {
  'DESCRIPTOR' : _SHUTDOWNRAYLETREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.ShutdownRayletRequest)
  })
_sym_db.RegisterMessage(ShutdownRayletRequest)

ShutdownRayletReply = _reflection.GeneratedProtocolMessageType('ShutdownRayletReply', (_message.Message,), {
  'DESCRIPTOR' : _SHUTDOWNRAYLETREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.ShutdownRayletReply)
  })
_sym_db.RegisterMessage(ShutdownRayletReply)

CancelWorkerLeaseRequest = _reflection.GeneratedProtocolMessageType('CancelWorkerLeaseRequest', (_message.Message,), {
  'DESCRIPTOR' : _CANCELWORKERLEASEREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.CancelWorkerLeaseRequest)
  })
_sym_db.RegisterMessage(CancelWorkerLeaseRequest)

CancelWorkerLeaseReply = _reflection.GeneratedProtocolMessageType('CancelWorkerLeaseReply', (_message.Message,), {
  'DESCRIPTOR' : _CANCELWORKERLEASEREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.CancelWorkerLeaseReply)
  })
_sym_db.RegisterMessage(CancelWorkerLeaseReply)

PinObjectIDsRequest = _reflection.GeneratedProtocolMessageType('PinObjectIDsRequest', (_message.Message,), {
  'DESCRIPTOR' : _PINOBJECTIDSREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.PinObjectIDsRequest)
  })
_sym_db.RegisterMessage(PinObjectIDsRequest)

PinObjectIDsReply = _reflection.GeneratedProtocolMessageType('PinObjectIDsReply', (_message.Message,), {
  'DESCRIPTOR' : _PINOBJECTIDSREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.PinObjectIDsReply)
  })
_sym_db.RegisterMessage(PinObjectIDsReply)

GetNodeStatsRequest = _reflection.GeneratedProtocolMessageType('GetNodeStatsRequest', (_message.Message,), {
  'DESCRIPTOR' : _GETNODESTATSREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.GetNodeStatsRequest)
  })
_sym_db.RegisterMessage(GetNodeStatsRequest)

ObjectStoreStats = _reflection.GeneratedProtocolMessageType('ObjectStoreStats', (_message.Message,), {
  'DESCRIPTOR' : _OBJECTSTORESTATS,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.ObjectStoreStats)
  })
_sym_db.RegisterMessage(ObjectStoreStats)

GetNodeStatsReply = _reflection.GeneratedProtocolMessageType('GetNodeStatsReply', (_message.Message,), {
  'DESCRIPTOR' : _GETNODESTATSREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.GetNodeStatsReply)
  })
_sym_db.RegisterMessage(GetNodeStatsReply)

GlobalGCRequest = _reflection.GeneratedProtocolMessageType('GlobalGCRequest', (_message.Message,), {
  'DESCRIPTOR' : _GLOBALGCREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.GlobalGCRequest)
  })
_sym_db.RegisterMessage(GlobalGCRequest)

GlobalGCReply = _reflection.GeneratedProtocolMessageType('GlobalGCReply', (_message.Message,), {
  'DESCRIPTOR' : _GLOBALGCREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.GlobalGCReply)
  })
_sym_db.RegisterMessage(GlobalGCReply)

FormatGlobalMemoryInfoRequest = _reflection.GeneratedProtocolMessageType('FormatGlobalMemoryInfoRequest', (_message.Message,), {
  'DESCRIPTOR' : _FORMATGLOBALMEMORYINFOREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.FormatGlobalMemoryInfoRequest)
  })
_sym_db.RegisterMessage(FormatGlobalMemoryInfoRequest)

FormatGlobalMemoryInfoReply = _reflection.GeneratedProtocolMessageType('FormatGlobalMemoryInfoReply', (_message.Message,), {
  'DESCRIPTOR' : _FORMATGLOBALMEMORYINFOREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.FormatGlobalMemoryInfoReply)
  })
_sym_db.RegisterMessage(FormatGlobalMemoryInfoReply)

ReleaseUnusedBundlesRequest = _reflection.GeneratedProtocolMessageType('ReleaseUnusedBundlesRequest', (_message.Message,), {
  'DESCRIPTOR' : _RELEASEUNUSEDBUNDLESREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.ReleaseUnusedBundlesRequest)
  })
_sym_db.RegisterMessage(ReleaseUnusedBundlesRequest)

ReleaseUnusedBundlesReply = _reflection.GeneratedProtocolMessageType('ReleaseUnusedBundlesReply', (_message.Message,), {
  'DESCRIPTOR' : _RELEASEUNUSEDBUNDLESREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.ReleaseUnusedBundlesReply)
  })
_sym_db.RegisterMessage(ReleaseUnusedBundlesReply)

GetSystemConfigRequest = _reflection.GeneratedProtocolMessageType('GetSystemConfigRequest', (_message.Message,), {
  'DESCRIPTOR' : _GETSYSTEMCONFIGREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.GetSystemConfigRequest)
  })
_sym_db.RegisterMessage(GetSystemConfigRequest)

GetSystemConfigReply = _reflection.GeneratedProtocolMessageType('GetSystemConfigReply', (_message.Message,), {
  'DESCRIPTOR' : _GETSYSTEMCONFIGREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.GetSystemConfigReply)
  })
_sym_db.RegisterMessage(GetSystemConfigReply)

GetObjectsInfoRequest = _reflection.GeneratedProtocolMessageType('GetObjectsInfoRequest', (_message.Message,), {
  'DESCRIPTOR' : _GETOBJECTSINFOREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.GetObjectsInfoRequest)
  })
_sym_db.RegisterMessage(GetObjectsInfoRequest)

GetObjectsInfoReply = _reflection.GeneratedProtocolMessageType('GetObjectsInfoReply', (_message.Message,), {
  'DESCRIPTOR' : _GETOBJECTSINFOREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.GetObjectsInfoReply)
  })
_sym_db.RegisterMessage(GetObjectsInfoReply)

GetResourceLoadRequest = _reflection.GeneratedProtocolMessageType('GetResourceLoadRequest', (_message.Message,), {
  'DESCRIPTOR' : _GETRESOURCELOADREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.GetResourceLoadRequest)
  })
_sym_db.RegisterMessage(GetResourceLoadRequest)

GetResourceLoadReply = _reflection.GeneratedProtocolMessageType('GetResourceLoadReply', (_message.Message,), {
  'DESCRIPTOR' : _GETRESOURCELOADREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.GetResourceLoadReply)
  })
_sym_db.RegisterMessage(GetResourceLoadReply)

CancelLeasesWithResourceShapesRequest = _reflection.GeneratedProtocolMessageType('CancelLeasesWithResourceShapesRequest', (_message.Message,), {

  'ResourceShape' : _reflection.GeneratedProtocolMessageType('ResourceShape', (_message.Message,), {

    'ResourceShapeEntry' : _reflection.GeneratedProtocolMessageType('ResourceShapeEntry', (_message.Message,), {
      'DESCRIPTOR' : _CANCELLEASESWITHRESOURCESHAPESREQUEST_RESOURCESHAPE_RESOURCESHAPEENTRY,
      '__module__' : 'src.ray.protobuf.node_manager_pb2'
      # @@protoc_insertion_point(class_scope:ray.rpc.CancelLeasesWithResourceShapesRequest.ResourceShape.ResourceShapeEntry)
      })
    ,
    'DESCRIPTOR' : _CANCELLEASESWITHRESOURCESHAPESREQUEST_RESOURCESHAPE,
    '__module__' : 'src.ray.protobuf.node_manager_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.CancelLeasesWithResourceShapesRequest.ResourceShape)
    })
  ,
  'DESCRIPTOR' : _CANCELLEASESWITHRESOURCESHAPESREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.CancelLeasesWithResourceShapesRequest)
  })
_sym_db.RegisterMessage(CancelLeasesWithResourceShapesRequest)
_sym_db.RegisterMessage(CancelLeasesWithResourceShapesRequest.ResourceShape)
_sym_db.RegisterMessage(CancelLeasesWithResourceShapesRequest.ResourceShape.ResourceShapeEntry)

CancelLeasesWithResourceShapesReply = _reflection.GeneratedProtocolMessageType('CancelLeasesWithResourceShapesReply', (_message.Message,), {
  'DESCRIPTOR' : _CANCELLEASESWITHRESOURCESHAPESREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.CancelLeasesWithResourceShapesReply)
  })
_sym_db.RegisterMessage(CancelLeasesWithResourceShapesReply)

NotifyGCSRestartRequest = _reflection.GeneratedProtocolMessageType('NotifyGCSRestartRequest', (_message.Message,), {
  'DESCRIPTOR' : _NOTIFYGCSRESTARTREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.NotifyGCSRestartRequest)
  })
_sym_db.RegisterMessage(NotifyGCSRestartRequest)

NotifyGCSRestartReply = _reflection.GeneratedProtocolMessageType('NotifyGCSRestartReply', (_message.Message,), {
  'DESCRIPTOR' : _NOTIFYGCSRESTARTREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.NotifyGCSRestartReply)
  })
_sym_db.RegisterMessage(NotifyGCSRestartReply)

GetWorkerFailureCauseRequest = _reflection.GeneratedProtocolMessageType('GetWorkerFailureCauseRequest', (_message.Message,), {
  'DESCRIPTOR' : _GETWORKERFAILURECAUSEREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.GetWorkerFailureCauseRequest)
  })
_sym_db.RegisterMessage(GetWorkerFailureCauseRequest)

GetWorkerFailureCauseReply = _reflection.GeneratedProtocolMessageType('GetWorkerFailureCauseReply', (_message.Message,), {
  'DESCRIPTOR' : _GETWORKERFAILURECAUSEREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.GetWorkerFailureCauseReply)
  })
_sym_db.RegisterMessage(GetWorkerFailureCauseReply)

DrainRayletRequest = _reflection.GeneratedProtocolMessageType('DrainRayletRequest', (_message.Message,), {
  'DESCRIPTOR' : _DRAINRAYLETREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.DrainRayletRequest)
  })
_sym_db.RegisterMessage(DrainRayletRequest)

DrainRayletReply = _reflection.GeneratedProtocolMessageType('DrainRayletReply', (_message.Message,), {
  'DESCRIPTOR' : _DRAINRAYLETREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.DrainRayletReply)
  })
_sym_db.RegisterMessage(DrainRayletReply)

RegisterMutableObjectRequest = _reflection.GeneratedProtocolMessageType('RegisterMutableObjectRequest', (_message.Message,), {
  'DESCRIPTOR' : _REGISTERMUTABLEOBJECTREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.RegisterMutableObjectRequest)
  })
_sym_db.RegisterMessage(RegisterMutableObjectRequest)

RegisterMutableObjectReply = _reflection.GeneratedProtocolMessageType('RegisterMutableObjectReply', (_message.Message,), {
  'DESCRIPTOR' : _REGISTERMUTABLEOBJECTREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.RegisterMutableObjectReply)
  })
_sym_db.RegisterMessage(RegisterMutableObjectReply)

PushMutableObjectRequest = _reflection.GeneratedProtocolMessageType('PushMutableObjectRequest', (_message.Message,), {
  'DESCRIPTOR' : _PUSHMUTABLEOBJECTREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.PushMutableObjectRequest)
  })
_sym_db.RegisterMessage(PushMutableObjectRequest)

PushMutableObjectReply = _reflection.GeneratedProtocolMessageType('PushMutableObjectReply', (_message.Message,), {
  'DESCRIPTOR' : _PUSHMUTABLEOBJECTREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.PushMutableObjectReply)
  })
_sym_db.RegisterMessage(PushMutableObjectReply)

IsLocalWorkerDeadRequest = _reflection.GeneratedProtocolMessageType('IsLocalWorkerDeadRequest', (_message.Message,), {
  'DESCRIPTOR' : _ISLOCALWORKERDEADREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.IsLocalWorkerDeadRequest)
  })
_sym_db.RegisterMessage(IsLocalWorkerDeadRequest)

IsLocalWorkerDeadReply = _reflection.GeneratedProtocolMessageType('IsLocalWorkerDeadReply', (_message.Message,), {
  'DESCRIPTOR' : _ISLOCALWORKERDEADREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.IsLocalWorkerDeadReply)
  })
_sym_db.RegisterMessage(IsLocalWorkerDeadReply)

GetWorkerPIDsRequest = _reflection.GeneratedProtocolMessageType('GetWorkerPIDsRequest', (_message.Message,), {
  'DESCRIPTOR' : _GETWORKERPIDSREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.GetWorkerPIDsRequest)
  })
_sym_db.RegisterMessage(GetWorkerPIDsRequest)

GetWorkerPIDsReply = _reflection.GeneratedProtocolMessageType('GetWorkerPIDsReply', (_message.Message,), {
  'DESCRIPTOR' : _GETWORKERPIDSREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.GetWorkerPIDsReply)
  })
_sym_db.RegisterMessage(GetWorkerPIDsReply)

KillLocalActorRequest = _reflection.GeneratedProtocolMessageType('KillLocalActorRequest', (_message.Message,), {
  'DESCRIPTOR' : _KILLLOCALACTORREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.KillLocalActorRequest)
  })
_sym_db.RegisterMessage(KillLocalActorRequest)

KillLocalActorReply = _reflection.GeneratedProtocolMessageType('KillLocalActorReply', (_message.Message,), {
  'DESCRIPTOR' : _KILLLOCALACTORREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.KillLocalActorReply)
  })
_sym_db.RegisterMessage(KillLocalActorReply)

CancelLocalTaskRequest = _reflection.GeneratedProtocolMessageType('CancelLocalTaskRequest', (_message.Message,), {
  'DESCRIPTOR' : _CANCELLOCALTASKREQUEST,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.CancelLocalTaskRequest)
  })
_sym_db.RegisterMessage(CancelLocalTaskRequest)

CancelLocalTaskReply = _reflection.GeneratedProtocolMessageType('CancelLocalTaskReply', (_message.Message,), {
  'DESCRIPTOR' : _CANCELLOCALTASKREPLY,
  '__module__' : 'src.ray.protobuf.node_manager_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.CancelLocalTaskReply)
  })
_sym_db.RegisterMessage(CancelLocalTaskReply)

_NODEMANAGERSERVICE = DESCRIPTOR.services_by_name['NodeManagerService']
if _descriptor._USE_C_DESCRIPTORS == False:

  DESCRIPTOR._options = None
  _RESIZELOCALRESOURCEINSTANCESREQUEST_RESOURCESENTRY._options = None
  _RESIZELOCALRESOURCEINSTANCESREQUEST_RESOURCESENTRY._serialized_options = b'8\001'
  _RESIZELOCALRESOURCEINSTANCESREPLY_TOTALRESOURCESENTRY._options = None
  _RESIZELOCALRESOURCEINSTANCESREPLY_TOTALRESOURCESENTRY._serialized_options = b'8\001'
  _CANCELLEASESWITHRESOURCESHAPESREQUEST_RESOURCESHAPE_RESOURCESHAPEENTRY._options = None
  _CANCELLEASESWITHRESOURCESHAPESREQUEST_RESOURCESHAPE_RESOURCESHAPEENTRY._serialized_options = b'8\001'
  _WORKERBACKLOGREPORT._serialized_start=193
  _WORKERBACKLOGREPORT._serialized_end=300
  _REPORTWORKERBACKLOGREQUEST._serialized_start=303
  _REPORTWORKERBACKLOGREQUEST._serialized_end=431
  _REPORTWORKERBACKLOGREPLY._serialized_start=433
  _REPORTWORKERBACKLOGREPLY._serialized_end=459
  _REQUESTWORKERLEASEREQUEST._serialized_start=462
  _REQUESTWORKERLEASEREQUEST._serialized_end=681
  _REQUESTWORKERLEASEREPLY._serialized_start=684
  _REQUESTWORKERLEASEREPLY._serialized_end=1453
  _REQUESTWORKERLEASEREPLY_SCHEDULINGFAILURETYPE._serialized_start=1215
  _REQUESTWORKERLEASEREPLY_SCHEDULINGFAILURETYPE._serialized_end=1453
  _PRESTARTWORKERSREQUEST._serialized_start=1456
  _PRESTARTWORKERSREQUEST._serialized_end=1723
  _PRESTARTWORKERSREPLY._serialized_start=1725
  _PRESTARTWORKERSREPLY._serialized_end=1747
  _PREPAREBUNDLERESOURCESREQUEST._serialized_start=1749
  _PREPAREBUNDLERESOURCESREQUEST._serialized_end=1832
  _PREPAREBUNDLERESOURCESREPLY._serialized_start=1834
  _PREPAREBUNDLERESOURCESREPLY._serialized_end=1889
  _COMMITBUNDLERESOURCESREQUEST._serialized_start=1891
  _COMMITBUNDLERESOURCESREQUEST._serialized_end=1973
  _COMMITBUNDLERESOURCESREPLY._serialized_start=1975
  _COMMITBUNDLERESOURCESREPLY._serialized_end=2003
  _CANCELRESOURCERESERVEREQUEST._serialized_start=2005
  _CANCELRESOURCERESERVEREQUEST._serialized_end=2085
  _CANCELRESOURCERESERVEREPLY._serialized_start=2087
  _CANCELRESOURCERESERVEREPLY._serialized_end=2115
  _RESIZELOCALRESOURCEINSTANCESREQUEST._serialized_start=2118
  _RESIZELOCALRESOURCEINSTANCESREQUEST._serialized_end=2308
  _RESIZELOCALRESOURCEINSTANCESREQUEST_RESOURCESENTRY._serialized_start=2248
  _RESIZELOCALRESOURCEINSTANCESREQUEST_RESOURCESENTRY._serialized_end=2308
  _RESIZELOCALRESOURCEINSTANCESREPLY._serialized_start=2311
  _RESIZELOCALRESOURCEINSTANCESREPLY._serialized_end=2518
  _RESIZELOCALRESOURCEINSTANCESREPLY_TOTALRESOURCESENTRY._serialized_start=2453
  _RESIZELOCALRESOURCEINSTANCESREPLY_TOTALRESOURCESENTRY._serialized_end=2518
  _RETURNWORKERLEASEREQUEST._serialized_start=2521
  _RETURNWORKERLEASEREQUEST._serialized_end=2760
  _RETURNWORKERLEASEREPLY._serialized_start=2762
  _RETURNWORKERLEASEREPLY._serialized_end=2786
  _RELEASEUNUSEDACTORWORKERSREQUEST._serialized_start=2788
  _RELEASEUNUSEDACTORWORKERSREQUEST._serialized_end=2865
  _RELEASEUNUSEDACTORWORKERSREPLY._serialized_start=2867
  _RELEASEUNUSEDACTORWORKERSREPLY._serialized_end=2899
  _SHUTDOWNRAYLETREQUEST._serialized_start=2901
  _SHUTDOWNRAYLETREQUEST._serialized_end=2952
  _SHUTDOWNRAYLETREPLY._serialized_start=2954
  _SHUTDOWNRAYLETREPLY._serialized_end=2975
  _CANCELWORKERLEASEREQUEST._serialized_start=2977
  _CANCELWORKERLEASEREQUEST._serialized_end=3030
  _CANCELWORKERLEASEREPLY._serialized_start=3032
  _CANCELWORKERLEASEREPLY._serialized_end=3082
  _PINOBJECTIDSREQUEST._serialized_start=3085
  _PINOBJECTIDSREQUEST._serialized_end=3249
  _PINOBJECTIDSREPLY._serialized_start=3251
  _PINOBJECTIDSREPLY._serialized_end=3300
  _GETNODESTATSREQUEST._serialized_start=3302
  _GETNODESTATSREQUEST._serialized_end=3371
  _OBJECTSTORESTATS._serialized_start=3374
  _OBJECTSTORESTATS._serialized_end=4217
  _GETNODESTATSREPLY._serialized_start=4220
  _GETNODESTATSREPLY._serialized_end=4404
  _GLOBALGCREQUEST._serialized_start=4406
  _GLOBALGCREQUEST._serialized_end=4423
  _GLOBALGCREPLY._serialized_start=4425
  _GLOBALGCREPLY._serialized_end=4440
  _FORMATGLOBALMEMORYINFOREQUEST._serialized_start=4442
  _FORMATGLOBALMEMORYINFOREQUEST._serialized_end=4521
  _FORMATGLOBALMEMORYINFOREPLY._serialized_start=4524
  _FORMATGLOBALMEMORYINFOREPLY._serialized_end=4652
  _RELEASEUNUSEDBUNDLESREQUEST._serialized_start=4654
  _RELEASEUNUSEDBUNDLESREQUEST._serialized_end=4738
  _RELEASEUNUSEDBUNDLESREPLY._serialized_start=4740
  _RELEASEUNUSEDBUNDLESREPLY._serialized_end=4767
  _GETSYSTEMCONFIGREQUEST._serialized_start=4769
  _GETSYSTEMCONFIGREQUEST._serialized_end=4793
  _GETSYSTEMCONFIGREPLY._serialized_start=4795
  _GETSYSTEMCONFIGREPLY._serialized_end=4854
  _GETOBJECTSINFOREQUEST._serialized_start=4856
  _GETOBJECTSINFOREQUEST._serialized_end=4916
  _GETOBJECTSINFOREPLY._serialized_start=4918
  _GETOBJECTSINFOREPLY._serialized_end=5033
  _GETRESOURCELOADREQUEST._serialized_start=5035
  _GETRESOURCELOADREQUEST._serialized_end=5059
  _GETRESOURCELOADREPLY._serialized_start=5061
  _GETRESOURCELOADREPLY._serialized_end=5137
  _CANCELLEASESWITHRESOURCESHAPESREQUEST._serialized_start=5140
  _CANCELLEASESWITHRESOURCESHAPESREQUEST._serialized_end=5486
  _CANCELLEASESWITHRESOURCESHAPESREQUEST_RESOURCESHAPE._serialized_start=5285
  _CANCELLEASESWITHRESOURCESHAPESREQUEST_RESOURCESHAPE._serialized_end=5486
  _CANCELLEASESWITHRESOURCESHAPESREQUEST_RESOURCESHAPE_RESOURCESHAPEENTRY._serialized_start=5422
  _CANCELLEASESWITHRESOURCESHAPESREQUEST_RESOURCESHAPE_RESOURCESHAPEENTRY._serialized_end=5486
  _CANCELLEASESWITHRESOURCESHAPESREPLY._serialized_start=5488
  _CANCELLEASESWITHRESOURCESHAPESREPLY._serialized_end=5525
  _NOTIFYGCSRESTARTREQUEST._serialized_start=5527
  _NOTIFYGCSRESTARTREQUEST._serialized_end=5552
  _NOTIFYGCSRESTARTREPLY._serialized_start=5554
  _NOTIFYGCSRESTARTREPLY._serialized_end=5577
  _GETWORKERFAILURECAUSEREQUEST._serialized_start=5579
  _GETWORKERFAILURECAUSEREQUEST._serialized_end=5636
  _GETWORKERFAILURECAUSEREPLY._serialized_start=5639
  _GETWORKERFAILURECAUSEREPLY._serialized_end=5802
  _DRAINRAYLETREQUEST._serialized_start=5805
  _DRAINRAYLETREQUEST._serialized_end=5977
  _DRAINRAYLETREPLY._serialized_start=5979
  _DRAINRAYLETREPLY._serialized_end=6088
  _REGISTERMUTABLEOBJECTREQUEST._serialized_start=6091
  _REGISTERMUTABLEOBJECTREQUEST._serialized_end=6238
  _REGISTERMUTABLEOBJECTREPLY._serialized_start=6240
  _REGISTERMUTABLEOBJECTREPLY._serialized_end=6268
  _PUSHMUTABLEOBJECTREQUEST._serialized_start=6271
  _PUSHMUTABLEOBJECTREQUEST._serialized_end=6530
  _PUSHMUTABLEOBJECTREPLY._serialized_start=6532
  _PUSHMUTABLEOBJECTREPLY._serialized_end=6576
  _ISLOCALWORKERDEADREQUEST._serialized_start=6578
  _ISLOCALWORKERDEADREQUEST._serialized_end=6633
  _ISLOCALWORKERDEADREPLY._serialized_start=6635
  _ISLOCALWORKERDEADREPLY._serialized_end=6684
  _GETWORKERPIDSREQUEST._serialized_start=6686
  _GETWORKERPIDSREQUEST._serialized_end=6708
  _GETWORKERPIDSREPLY._serialized_start=6710
  _GETWORKERPIDSREPLY._serialized_end=6750
  _KILLLOCALACTORREQUEST._serialized_start=6753
  _KILLLOCALACTORREQUEST._serialized_end=6939
  _KILLLOCALACTORREPLY._serialized_start=6941
  _KILLLOCALACTORREPLY._serialized_end=6962
  _CANCELLOCALTASKREQUEST._serialized_start=6965
  _CANCELLOCALTASKREQUEST._serialized_end=7180
  _CANCELLOCALTASKREPLY._serialized_start=7182
  _CANCELLOCALTASKREPLY._serialized_end=7303
  _NODEMANAGERSERVICE._serialized_start=7306
  _NODEMANAGERSERVICE._serialized_end=9958
# @@protoc_insertion_point(module_scope)