# -*- 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_env_common_pb2 as src_dot_ray_dot_protobuf_dot_runtime__env__common__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)src/ray/protobuf/runtime_env_common.proto\"p\n\x13WorkerBacklogReport\x12\x36\n\rresource_spec\x18\x01 \x01(\x0b\x32\x11.ray.rpc.TaskSpecR\x0cresourceSpec\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\"\xe0\x01\n\x19RequestWorkerLeaseRequest\x12\x36\n\rresource_spec\x18\x01 \x01(\x0b\x32\x11.ray.rpc.TaskSpecR\x0cresourceSpec\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\"\xec\x01\n\x13ReturnWorkerRequest\x12\x1f\n\x0bworker_port\x18\x01 \x01(\x05R\nworkerPort\x12\x1b\n\tworker_id\x18\x02 \x01(\x0cR\x08workerId\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\"\x13\n\x11ReturnWorkerReply\"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\"3\n\x18\x43\x61ncelWorkerLeaseRequest\x12\x17\n\x07task_id\x18\x01 \x01(\x0cR\x06taskId\"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\"\xf2\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\x0e\x63onsumed_bytes\x18\x0c \x01(\x03R\rconsumedBytes\x12.\n\x13object_pulls_queued\x18\r \x01(\x08R\x11objectPullsQueued\x12\x44\n\x1fnum_object_store_primary_copies\x18\x0e \x01(\x03R\x1bnumObjectStorePrimaryCopies\x12<\n\x1a\x63umulative_created_objects\x18\x0f \x01(\x03R\x18\x63umulativeCreatedObjects\x12\x38\n\x18\x63umulative_created_bytes\x18\x10 \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\"\xd7\x02\n$CancelTasksWithResourceShapesRequest\x12\x64\n\x0fresource_shapes\x18\x01 \x03(\x0b\x32;.ray.rpc.CancelTasksWithResourceShapesRequest.ResourceShapeR\x0eresourceShapes\x1a\xc8\x01\n\rResourceShape\x12u\n\x0eresource_shape\x18\x01 \x03(\x0b\x32N.ray.rpc.CancelTasksWithResourceShapesRequest.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\"CancelTasksWithResourceShapesReply\"\x19\n\x17NotifyGCSRestartRequest\"\x17\n\x15NotifyGCSRestartReply\"5\n\x1aGetTaskFailureCauseRequest\x12\x17\n\x07task_id\x18\x01 \x01(\x0cR\x06taskId\"\xa1\x01\n\x18GetTaskFailureCauseReply\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\x06isDead2\xda\x11\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\x1d\x43\x61ncelTasksWithResourceShapes\x12-.ray.rpc.CancelTasksWithResourceShapesRequest\x1a+.ray.rpc.CancelTasksWithResourceShapesReply\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\x12H\n\x0cReturnWorker\x12\x1c.ray.rpc.ReturnWorkerRequest\x1a\x1a.ray.rpc.ReturnWorkerReply\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\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]\n\x13GetTaskFailureCause\x12#.ray.rpc.GetTaskFailureCauseRequest\x1a!.ray.rpc.GetTaskFailureCauseReply\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.IsLocalWorkerDeadReplyb\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'] _RETURNWORKERREQUEST = DESCRIPTOR.message_types_by_name['ReturnWorkerRequest'] _RETURNWORKERREPLY = DESCRIPTOR.message_types_by_name['ReturnWorkerReply'] _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'] _CANCELTASKSWITHRESOURCESHAPESREQUEST = DESCRIPTOR.message_types_by_name['CancelTasksWithResourceShapesRequest'] _CANCELTASKSWITHRESOURCESHAPESREQUEST_RESOURCESHAPE = _CANCELTASKSWITHRESOURCESHAPESREQUEST.nested_types_by_name['ResourceShape'] _CANCELTASKSWITHRESOURCESHAPESREQUEST_RESOURCESHAPE_RESOURCESHAPEENTRY = _CANCELTASKSWITHRESOURCESHAPESREQUEST_RESOURCESHAPE.nested_types_by_name['ResourceShapeEntry'] _CANCELTASKSWITHRESOURCESHAPESREPLY = DESCRIPTOR.message_types_by_name['CancelTasksWithResourceShapesReply'] _NOTIFYGCSRESTARTREQUEST = DESCRIPTOR.message_types_by_name['NotifyGCSRestartRequest'] _NOTIFYGCSRESTARTREPLY = DESCRIPTOR.message_types_by_name['NotifyGCSRestartReply'] _GETTASKFAILURECAUSEREQUEST = DESCRIPTOR.message_types_by_name['GetTaskFailureCauseRequest'] _GETTASKFAILURECAUSEREPLY = DESCRIPTOR.message_types_by_name['GetTaskFailureCauseReply'] _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'] _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) ReturnWorkerRequest = _reflection.GeneratedProtocolMessageType('ReturnWorkerRequest', (_message.Message,), { 'DESCRIPTOR' : _RETURNWORKERREQUEST, '__module__' : 'src.ray.protobuf.node_manager_pb2' # @@protoc_insertion_point(class_scope:ray.rpc.ReturnWorkerRequest) }) _sym_db.RegisterMessage(ReturnWorkerRequest) ReturnWorkerReply = _reflection.GeneratedProtocolMessageType('ReturnWorkerReply', (_message.Message,), { 'DESCRIPTOR' : _RETURNWORKERREPLY, '__module__' : 'src.ray.protobuf.node_manager_pb2' # @@protoc_insertion_point(class_scope:ray.rpc.ReturnWorkerReply) }) _sym_db.RegisterMessage(ReturnWorkerReply) 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) CancelTasksWithResourceShapesRequest = _reflection.GeneratedProtocolMessageType('CancelTasksWithResourceShapesRequest', (_message.Message,), { 'ResourceShape' : _reflection.GeneratedProtocolMessageType('ResourceShape', (_message.Message,), { 'ResourceShapeEntry' : _reflection.GeneratedProtocolMessageType('ResourceShapeEntry', (_message.Message,), { 'DESCRIPTOR' : _CANCELTASKSWITHRESOURCESHAPESREQUEST_RESOURCESHAPE_RESOURCESHAPEENTRY, '__module__' : 'src.ray.protobuf.node_manager_pb2' # @@protoc_insertion_point(class_scope:ray.rpc.CancelTasksWithResourceShapesRequest.ResourceShape.ResourceShapeEntry) }) , 'DESCRIPTOR' : _CANCELTASKSWITHRESOURCESHAPESREQUEST_RESOURCESHAPE, '__module__' : 'src.ray.protobuf.node_manager_pb2' # @@protoc_insertion_point(class_scope:ray.rpc.CancelTasksWithResourceShapesRequest.ResourceShape) }) , 'DESCRIPTOR' : _CANCELTASKSWITHRESOURCESHAPESREQUEST, '__module__' : 'src.ray.protobuf.node_manager_pb2' # @@protoc_insertion_point(class_scope:ray.rpc.CancelTasksWithResourceShapesRequest) }) _sym_db.RegisterMessage(CancelTasksWithResourceShapesRequest) _sym_db.RegisterMessage(CancelTasksWithResourceShapesRequest.ResourceShape) _sym_db.RegisterMessage(CancelTasksWithResourceShapesRequest.ResourceShape.ResourceShapeEntry) CancelTasksWithResourceShapesReply = _reflection.GeneratedProtocolMessageType('CancelTasksWithResourceShapesReply', (_message.Message,), { 'DESCRIPTOR' : _CANCELTASKSWITHRESOURCESHAPESREPLY, '__module__' : 'src.ray.protobuf.node_manager_pb2' # @@protoc_insertion_point(class_scope:ray.rpc.CancelTasksWithResourceShapesReply) }) _sym_db.RegisterMessage(CancelTasksWithResourceShapesReply) 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) GetTaskFailureCauseRequest = _reflection.GeneratedProtocolMessageType('GetTaskFailureCauseRequest', (_message.Message,), { 'DESCRIPTOR' : _GETTASKFAILURECAUSEREQUEST, '__module__' : 'src.ray.protobuf.node_manager_pb2' # @@protoc_insertion_point(class_scope:ray.rpc.GetTaskFailureCauseRequest) }) _sym_db.RegisterMessage(GetTaskFailureCauseRequest) GetTaskFailureCauseReply = _reflection.GeneratedProtocolMessageType('GetTaskFailureCauseReply', (_message.Message,), { 'DESCRIPTOR' : _GETTASKFAILURECAUSEREPLY, '__module__' : 'src.ray.protobuf.node_manager_pb2' # @@protoc_insertion_point(class_scope:ray.rpc.GetTaskFailureCauseReply) }) _sym_db.RegisterMessage(GetTaskFailureCauseReply) 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) _NODEMANAGERSERVICE = DESCRIPTOR.services_by_name['NodeManagerService'] if _descriptor._USE_C_DESCRIPTORS == False: DESCRIPTOR._options = None _CANCELTASKSWITHRESOURCESHAPESREQUEST_RESOURCESHAPE_RESOURCESHAPEENTRY._options = None _CANCELTASKSWITHRESOURCESHAPESREQUEST_RESOURCESHAPE_RESOURCESHAPEENTRY._serialized_options = b'8\001' _WORKERBACKLOGREPORT._serialized_start=185 _WORKERBACKLOGREPORT._serialized_end=297 _REPORTWORKERBACKLOGREQUEST._serialized_start=300 _REPORTWORKERBACKLOGREQUEST._serialized_end=428 _REPORTWORKERBACKLOGREPLY._serialized_start=430 _REPORTWORKERBACKLOGREPLY._serialized_end=456 _REQUESTWORKERLEASEREQUEST._serialized_start=459 _REQUESTWORKERLEASEREQUEST._serialized_end=683 _REQUESTWORKERLEASEREPLY._serialized_start=686 _REQUESTWORKERLEASEREPLY._serialized_end=1455 _REQUESTWORKERLEASEREPLY_SCHEDULINGFAILURETYPE._serialized_start=1217 _REQUESTWORKERLEASEREPLY_SCHEDULINGFAILURETYPE._serialized_end=1455 _PRESTARTWORKERSREQUEST._serialized_start=1458 _PRESTARTWORKERSREQUEST._serialized_end=1725 _PRESTARTWORKERSREPLY._serialized_start=1727 _PRESTARTWORKERSREPLY._serialized_end=1749 _PREPAREBUNDLERESOURCESREQUEST._serialized_start=1751 _PREPAREBUNDLERESOURCESREQUEST._serialized_end=1834 _PREPAREBUNDLERESOURCESREPLY._serialized_start=1836 _PREPAREBUNDLERESOURCESREPLY._serialized_end=1891 _COMMITBUNDLERESOURCESREQUEST._serialized_start=1893 _COMMITBUNDLERESOURCESREQUEST._serialized_end=1975 _COMMITBUNDLERESOURCESREPLY._serialized_start=1977 _COMMITBUNDLERESOURCESREPLY._serialized_end=2005 _CANCELRESOURCERESERVEREQUEST._serialized_start=2007 _CANCELRESOURCERESERVEREQUEST._serialized_end=2087 _CANCELRESOURCERESERVEREPLY._serialized_start=2089 _CANCELRESOURCERESERVEREPLY._serialized_end=2117 _RETURNWORKERREQUEST._serialized_start=2120 _RETURNWORKERREQUEST._serialized_end=2356 _RETURNWORKERREPLY._serialized_start=2358 _RETURNWORKERREPLY._serialized_end=2377 _RELEASEUNUSEDACTORWORKERSREQUEST._serialized_start=2379 _RELEASEUNUSEDACTORWORKERSREQUEST._serialized_end=2456 _RELEASEUNUSEDACTORWORKERSREPLY._serialized_start=2458 _RELEASEUNUSEDACTORWORKERSREPLY._serialized_end=2490 _SHUTDOWNRAYLETREQUEST._serialized_start=2492 _SHUTDOWNRAYLETREQUEST._serialized_end=2543 _SHUTDOWNRAYLETREPLY._serialized_start=2545 _SHUTDOWNRAYLETREPLY._serialized_end=2566 _CANCELWORKERLEASEREQUEST._serialized_start=2568 _CANCELWORKERLEASEREQUEST._serialized_end=2619 _CANCELWORKERLEASEREPLY._serialized_start=2621 _CANCELWORKERLEASEREPLY._serialized_end=2671 _PINOBJECTIDSREQUEST._serialized_start=2674 _PINOBJECTIDSREQUEST._serialized_end=2838 _PINOBJECTIDSREPLY._serialized_start=2840 _PINOBJECTIDSREPLY._serialized_end=2889 _GETNODESTATSREQUEST._serialized_start=2891 _GETNODESTATSREQUEST._serialized_end=2960 _OBJECTSTORESTATS._serialized_start=2963 _OBJECTSTORESTATS._serialized_end=3845 _GETNODESTATSREPLY._serialized_start=3848 _GETNODESTATSREPLY._serialized_end=4032 _GLOBALGCREQUEST._serialized_start=4034 _GLOBALGCREQUEST._serialized_end=4051 _GLOBALGCREPLY._serialized_start=4053 _GLOBALGCREPLY._serialized_end=4068 _FORMATGLOBALMEMORYINFOREQUEST._serialized_start=4070 _FORMATGLOBALMEMORYINFOREQUEST._serialized_end=4149 _FORMATGLOBALMEMORYINFOREPLY._serialized_start=4152 _FORMATGLOBALMEMORYINFOREPLY._serialized_end=4280 _RELEASEUNUSEDBUNDLESREQUEST._serialized_start=4282 _RELEASEUNUSEDBUNDLESREQUEST._serialized_end=4366 _RELEASEUNUSEDBUNDLESREPLY._serialized_start=4368 _RELEASEUNUSEDBUNDLESREPLY._serialized_end=4395 _GETSYSTEMCONFIGREQUEST._serialized_start=4397 _GETSYSTEMCONFIGREQUEST._serialized_end=4421 _GETSYSTEMCONFIGREPLY._serialized_start=4423 _GETSYSTEMCONFIGREPLY._serialized_end=4482 _GETOBJECTSINFOREQUEST._serialized_start=4484 _GETOBJECTSINFOREQUEST._serialized_end=4544 _GETOBJECTSINFOREPLY._serialized_start=4546 _GETOBJECTSINFOREPLY._serialized_end=4661 _GETRESOURCELOADREQUEST._serialized_start=4663 _GETRESOURCELOADREQUEST._serialized_end=4687 _GETRESOURCELOADREPLY._serialized_start=4689 _GETRESOURCELOADREPLY._serialized_end=4765 _CANCELTASKSWITHRESOURCESHAPESREQUEST._serialized_start=4768 _CANCELTASKSWITHRESOURCESHAPESREQUEST._serialized_end=5111 _CANCELTASKSWITHRESOURCESHAPESREQUEST_RESOURCESHAPE._serialized_start=4911 _CANCELTASKSWITHRESOURCESHAPESREQUEST_RESOURCESHAPE._serialized_end=5111 _CANCELTASKSWITHRESOURCESHAPESREQUEST_RESOURCESHAPE_RESOURCESHAPEENTRY._serialized_start=5047 _CANCELTASKSWITHRESOURCESHAPESREQUEST_RESOURCESHAPE_RESOURCESHAPEENTRY._serialized_end=5111 _CANCELTASKSWITHRESOURCESHAPESREPLY._serialized_start=5113 _CANCELTASKSWITHRESOURCESHAPESREPLY._serialized_end=5149 _NOTIFYGCSRESTARTREQUEST._serialized_start=5151 _NOTIFYGCSRESTARTREQUEST._serialized_end=5176 _NOTIFYGCSRESTARTREPLY._serialized_start=5178 _NOTIFYGCSRESTARTREPLY._serialized_end=5201 _GETTASKFAILURECAUSEREQUEST._serialized_start=5203 _GETTASKFAILURECAUSEREQUEST._serialized_end=5256 _GETTASKFAILURECAUSEREPLY._serialized_start=5259 _GETTASKFAILURECAUSEREPLY._serialized_end=5420 _DRAINRAYLETREQUEST._serialized_start=5423 _DRAINRAYLETREQUEST._serialized_end=5595 _DRAINRAYLETREPLY._serialized_start=5597 _DRAINRAYLETREPLY._serialized_end=5706 _REGISTERMUTABLEOBJECTREQUEST._serialized_start=5709 _REGISTERMUTABLEOBJECTREQUEST._serialized_end=5856 _REGISTERMUTABLEOBJECTREPLY._serialized_start=5858 _REGISTERMUTABLEOBJECTREPLY._serialized_end=5886 _PUSHMUTABLEOBJECTREQUEST._serialized_start=5889 _PUSHMUTABLEOBJECTREQUEST._serialized_end=6148 _PUSHMUTABLEOBJECTREPLY._serialized_start=6150 _PUSHMUTABLEOBJECTREPLY._serialized_end=6194 _ISLOCALWORKERDEADREQUEST._serialized_start=6196 _ISLOCALWORKERDEADREQUEST._serialized_end=6251 _ISLOCALWORKERDEADREPLY._serialized_start=6253 _ISLOCALWORKERDEADREPLY._serialized_end=6302 _NODEMANAGERSERVICE._serialized_start=6305 _NODEMANAGERSERVICE._serialized_end=8571 # @@protoc_insertion_point(module_scope)