# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler.  DO NOT EDIT!
# source: src/ray/protobuf/gcs.proto
"""Generated protocol buffer code."""
from google.protobuf.internal import enum_type_wrapper
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 profile_events_pb2 as src_dot_ray_dot_protobuf_dot_profile__events__pb2


DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x1asrc/ray/protobuf/gcs.proto\x12\x07ray.rpc\x1a\x1dsrc/ray/protobuf/common.proto\x1a%src/ray/protobuf/profile_events.proto\"m\n\x08GcsEntry\x12\x37\n\x0b\x63hange_mode\x18\x01 \x01(\x0e\x32\x16.ray.rpc.GcsChangeModeR\nchangeMode\x12\x0e\n\x02id\x18\x02 \x01(\x0cR\x02id\x12\x18\n\x07\x65ntries\x18\x03 \x03(\x0cR\x07\x65ntries\"\xce\x0c\n\x0e\x41\x63torTableData\x12\x19\n\x08\x61\x63tor_id\x18\x01 \x01(\x0cR\x07\x61\x63torId\x12\x1b\n\tparent_id\x18\x02 \x01(\x0cR\x08parentId\x12\x15\n\x06job_id\x18\x04 \x01(\x0cR\x05jobId\x12\x38\n\x05state\x18\x06 \x01(\x0e\x32\".ray.rpc.ActorTableData.ActorStateR\x05state\x12!\n\x0cmax_restarts\x18\x07 \x01(\x03R\x0bmaxRestarts\x12!\n\x0cnum_restarts\x18\x08 \x01(\x03R\x0bnumRestarts\x12*\n\x07\x61\x64\x64ress\x18\t \x01(\x0b\x32\x10.ray.rpc.AddressR\x07\x61\x64\x64ress\x12\x35\n\rowner_address\x18\n \x01(\x0b\x32\x10.ray.rpc.AddressR\x0cownerAddress\x12\x1f\n\x0bis_detached\x18\x0b \x01(\x08R\nisDetached\x12\x12\n\x04name\x18\x0c \x01(\tR\x04name\x12\x1c\n\ttimestamp\x18\r \x01(\x01R\ttimestamp\x12\x44\n\x10resource_mapping\x18\x0f \x03(\x0b\x32\x19.ray.rpc.ResourceMapEntryR\x0fresourceMapping\x12\x10\n\x03pid\x18\x10 \x01(\rR\x03pid\x12L\n\x13\x66unction_descriptor\x18\x11 \x01(\x0b\x32\x1b.ray.rpc.FunctionDescriptorR\x12\x66unctionDescriptor\x12#\n\rray_namespace\x18\x13 \x01(\tR\x0crayNamespace\x12\x1d\n\nstart_time\x18\x14 \x01(\x04R\tstartTime\x12\x19\n\x08\x65nd_time\x18\x15 \x01(\x04R\x07\x65ndTime\x12\x34\n\x16serialized_runtime_env\x18\x16 \x01(\tR\x14serializedRuntimeEnv\x12\x1d\n\nclass_name\x18\x17 \x01(\tR\tclassName\x12\x39\n\x0b\x64\x65\x61th_cause\x18\x18 \x01(\x0b\x32\x18.ray.rpc.ActorDeathCauseR\ndeathCause\x12]\n\x12required_resources\x18\x1c \x03(\x0b\x32..ray.rpc.ActorTableData.RequiredResourcesEntryR\x11requiredResources\x12\x1c\n\x07node_id\x18\x1d \x01(\x0cH\x00R\x06nodeId\x88\x01\x01\x12\x31\n\x12placement_group_id\x18\x1e \x01(\x0cH\x01R\x10placementGroupId\x88\x01\x01\x12\x1b\n\trepr_name\x18\x1f \x01(\tR\x08reprName\x12\x1c\n\tpreempted\x18  \x01(\x08R\tpreempted\x12Y\n*num_restarts_due_to_lineage_reconstruction\x18! \x01(\x04R%numRestartsDueToLineageReconstruction\x12 \n\tcall_site\x18\" \x01(\tH\x02R\x08\x63\x61llSite\x88\x01\x01\x12Q\n\x0elabel_selector\x18# \x03(\x0b\x32*.ray.rpc.ActorTableData.LabelSelectorEntryR\rlabelSelector\x12K\n#num_restarts_due_to_node_preemption\x18$ \x01(\x04R\x1enumRestartsDueToNodePreemption\x1a\x44\n\x16RequiredResourcesEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\x01R\x05value:\x02\x38\x01\x1a@\n\x12LabelSelectorEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\"a\n\nActorState\x12\x18\n\x14\x44\x45PENDENCIES_UNREADY\x10\x00\x12\x14\n\x10PENDING_CREATION\x10\x01\x12\t\n\x05\x41LIVE\x10\x02\x12\x0e\n\nRESTARTING\x10\x03\x12\x08\n\x04\x44\x45\x41\x44\x10\x04\x42\n\n\x08_node_idB\x15\n\x13_placement_group_idB\x0c\n\n_call_site\"~\n\x0e\x45rrorTableData\x12\x15\n\x06job_id\x18\x01 \x01(\x0cR\x05jobId\x12\x12\n\x04type\x18\x02 \x01(\tR\x04type\x12#\n\rerror_message\x18\x03 \x01(\tR\x0c\x65rrorMessage\x12\x1c\n\ttimestamp\x18\x04 \x01(\x01R\ttimestamp\"\xd1\x02\n\x0bTaskLogInfo\x12$\n\x0bstdout_file\x18\x01 \x01(\tH\x00R\nstdoutFile\x88\x01\x01\x12$\n\x0bstderr_file\x18\x02 \x01(\tH\x01R\nstderrFile\x88\x01\x01\x12&\n\x0cstdout_start\x18\x03 \x01(\x05H\x02R\x0bstdoutStart\x88\x01\x01\x12\"\n\nstdout_end\x18\x04 \x01(\x05H\x03R\tstdoutEnd\x88\x01\x01\x12&\n\x0cstderr_start\x18\x05 \x01(\x05H\x04R\x0bstderrStart\x88\x01\x01\x12\"\n\nstderr_end\x18\x06 \x01(\x05H\x05R\tstderrEnd\x88\x01\x01\x42\x0e\n\x0c_stdout_fileB\x0e\n\x0c_stderr_fileB\x0f\n\r_stdout_startB\r\n\x0b_stdout_endB\x0f\n\r_stderr_startB\r\n\x0b_stderr_end\"\xcb\x04\n\x0fTaskStateUpdate\x12\x1c\n\x07node_id\x18\x01 \x01(\x0cH\x00R\x06nodeId\x88\x01\x01\x12 \n\tworker_id\x18\x08 \x01(\x0cH\x01R\x08workerId\x88\x01\x01\x12\x39\n\nerror_info\x18\t \x01(\x0b\x32\x15.ray.rpc.RayErrorInfoH\x02R\terrorInfo\x88\x01\x01\x12=\n\rtask_log_info\x18\n \x01(\x0b\x32\x14.ray.rpc.TaskLogInfoH\x03R\x0btaskLogInfo\x88\x01\x01\x12+\n\x0f\x61\x63tor_repr_name\x18\x0b \x01(\tH\x04R\ractorReprName\x88\x01\x01\x12\"\n\nworker_pid\x18\x0c \x01(\x05H\x05R\tworkerPid\x88\x01\x01\x12\x31\n\x12is_debugger_paused\x18\r \x01(\x08H\x06R\x10isDebuggerPaused\x88\x01\x01\x12G\n\x0bstate_ts_ns\x18\x0e \x03(\x0b\x32\'.ray.rpc.TaskStateUpdate.StateTsNsEntryR\tstateTsNs\x1a<\n\x0eStateTsNsEntry\x12\x10\n\x03key\x18\x01 \x01(\x05R\x03key\x12\x14\n\x05value\x18\x02 \x01(\x03R\x05value:\x02\x38\x01\x42\n\n\x08_node_idB\x0c\n\n_worker_idB\r\n\x0b_error_infoB\x10\n\x0e_task_log_infoB\x12\n\x10_actor_repr_nameB\r\n\x0b_worker_pidB\x15\n\x13_is_debugger_paused\"\xd8\x02\n\nTaskEvents\x12\x17\n\x07task_id\x18\x01 \x01(\x0cR\x06taskId\x12%\n\x0e\x61ttempt_number\x18\x02 \x01(\x05R\rattemptNumber\x12\x38\n\ttask_info\x18\x03 \x01(\x0b\x32\x16.ray.rpc.TaskInfoEntryH\x00R\x08taskInfo\x88\x01\x01\x12\x42\n\rstate_updates\x18\x04 \x01(\x0b\x32\x18.ray.rpc.TaskStateUpdateH\x01R\x0cstateUpdates\x88\x01\x01\x12\x42\n\x0eprofile_events\x18\x05 \x01(\x0b\x32\x16.ray.rpc.ProfileEventsH\x02R\rprofileEvents\x88\x01\x01\x12\x15\n\x06job_id\x18\x06 \x01(\x0cR\x05jobIdB\x0c\n\n_task_infoB\x10\n\x0e_state_updatesB\x11\n\x0f_profile_events\"\xe8\x01\n\rTaskEventData\x12\x39\n\x0e\x65vents_by_task\x18\x01 \x03(\x0b\x32\x13.ray.rpc.TaskEventsR\x0c\x65ventsByTask\x12H\n\x15\x64ropped_task_attempts\x18\x02 \x03(\x0b\x32\x14.ray.rpc.TaskAttemptR\x13\x64roppedTaskAttempts\x12;\n\x1anum_profile_events_dropped\x18\x03 \x01(\x05R\x17numProfileEventsDropped\x12\x15\n\x06job_id\x18\x04 \x01(\x0cR\x05jobId\"\xda\x01\n\x12\x41vailableResources\x12\x17\n\x07node_id\x18\x01 \x01(\x0cR\x06nodeId\x12\x64\n\x13resources_available\x18\x02 \x03(\x0b\x32\x33.ray.rpc.AvailableResources.ResourcesAvailableEntryR\x12resourcesAvailable\x1a\x45\n\x17ResourcesAvailableEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\x01R\x05value:\x02\x38\x01\"\xc2\x01\n\x0eTotalResources\x12\x17\n\x07node_id\x18\x01 \x01(\x0cR\x06nodeId\x12T\n\x0fresources_total\x18\x02 \x03(\x0b\x32+.ray.rpc.TotalResources.ResourcesTotalEntryR\x0eresourcesTotal\x1a\x41\n\x13ResourcesTotalEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\x01R\x05value:\x02\x38\x01\"\xcc\x01\n\x0cNodeSnapshot\x12\x31\n\x05state\x18\x01 \x01(\x0e\x32\x1b.ray.rpc.NodeSnapshot.StateR\x05state\x12(\n\x10idle_duration_ms\x18\x02 \x01(\x03R\x0eidleDurationMs\x12#\n\rnode_activity\x18\x03 \x03(\tR\x0cnodeActivity\":\n\x05State\x12\r\n\tUNDEFINED\x10\x00\x12\x08\n\x04IDLE\x10\x01\x12\n\n\x06\x41\x43TIVE\x10\x02\x12\x0c\n\x08\x44RAINING\x10\x03\"\x8a\t\n\x0bGcsNodeInfo\x12\x17\n\x07node_id\x18\x01 \x01(\x0cR\x06nodeId\x12\x30\n\x14node_manager_address\x18\x02 \x01(\tR\x12nodeManagerAddress\x12,\n\x12raylet_socket_name\x18\x03 \x01(\tR\x10rayletSocketName\x12\x37\n\x18object_store_socket_name\x18\x04 \x01(\tR\x15objectStoreSocketName\x12*\n\x11node_manager_port\x18\x05 \x01(\x05R\x0fnodeManagerPort\x12.\n\x13object_manager_port\x18\x06 \x01(\x05R\x11objectManagerPort\x12\x37\n\x05state\x18\x07 \x01(\x0e\x32!.ray.rpc.GcsNodeInfo.GcsNodeStateR\x05state\x12\x32\n\x15node_manager_hostname\x18\x08 \x01(\tR\x13nodeManagerHostname\x12.\n\x13metrics_export_port\x18\t \x01(\x05R\x11metricsExportPort\x12\x33\n\x16runtime_env_agent_port\x18\x1b \x01(\x05R\x13runtimeEnvAgentPort\x12Q\n\x0fresources_total\x18\x0b \x03(\x0b\x32(.ray.rpc.GcsNodeInfo.ResourcesTotalEntryR\x0eresourcesTotal\x12\x1b\n\tnode_name\x18\x0c \x01(\tR\x08nodeName\x12\x1f\n\x0binstance_id\x18\r \x01(\tR\ninstanceId\x12$\n\x0enode_type_name\x18\x0e \x01(\tR\x0cnodeTypeName\x12,\n\x12instance_type_name\x18\x0f \x01(\tR\x10instanceTypeName\x12\"\n\rstart_time_ms\x18\x17 \x01(\x04R\x0bstartTimeMs\x12\x1e\n\x0b\x65nd_time_ms\x18\x18 \x01(\x04R\tendTimeMs\x12 \n\x0cis_head_node\x18\x19 \x01(\x08R\nisHeadNode\x12\x38\n\x06labels\x18\x1a \x03(\x0b\x32 .ray.rpc.GcsNodeInfo.LabelsEntryR\x06labels\x12<\n\x0estate_snapshot\x18\x1c \x01(\x0b\x32\x15.ray.rpc.NodeSnapshotR\rstateSnapshot\x12\x35\n\ndeath_info\x18\x1d \x01(\x0b\x32\x16.ray.rpc.NodeDeathInfoR\tdeathInfo\x1a\x41\n\x13ResourcesTotalEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\x01R\x05value:\x02\x38\x01\x1a\x39\n\x0bLabelsEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\"#\n\x0cGcsNodeState\x12\t\n\x05\x41LIVE\x10\x00\x12\x08\n\x04\x44\x45\x41\x44\x10\x01\"\xb2\x02\n\x19GcsNodeAddressAndLiveness\x12\x17\n\x07node_id\x18\x01 \x01(\x0cR\x06nodeId\x12\x30\n\x14node_manager_address\x18\x02 \x01(\tR\x12nodeManagerAddress\x12*\n\x11node_manager_port\x18\x03 \x01(\x05R\x0fnodeManagerPort\x12.\n\x13object_manager_port\x18\x04 \x01(\x05R\x11objectManagerPort\x12\x37\n\x05state\x18\x05 \x01(\x0e\x32!.ray.rpc.GcsNodeInfo.GcsNodeStateR\x05state\x12\x35\n\ndeath_info\x18\x06 \x01(\x0b\x32\x16.ray.rpc.NodeDeathInfoR\tdeathInfo\"\xb0\x08\n\x0bJobsAPIInfo\x12\x16\n\x06status\x18\x01 \x01(\tR\x06status\x12\x1e\n\nentrypoint\x18\x02 \x01(\tR\nentrypoint\x12\x1d\n\x07message\x18\x03 \x01(\tH\x00R\x07message\x88\x01\x01\x12\"\n\nerror_type\x18\x04 \x01(\tH\x01R\terrorType\x88\x01\x01\x12\"\n\nstart_time\x18\x05 \x01(\x04H\x02R\tstartTime\x88\x01\x01\x12\x1e\n\x08\x65nd_time\x18\x06 \x01(\x04H\x03R\x07\x65ndTime\x88\x01\x01\x12>\n\x08metadata\x18\x07 \x03(\x0b\x32\".ray.rpc.JobsAPIInfo.MetadataEntryR\x08metadata\x12-\n\x10runtime_env_json\x18\x08 \x01(\tH\x04R\x0eruntimeEnvJson\x88\x01\x01\x12\x33\n\x13\x65ntrypoint_num_cpus\x18\t \x01(\x01H\x05R\x11\x65ntrypointNumCpus\x88\x01\x01\x12\x33\n\x13\x65ntrypoint_num_gpus\x18\n \x01(\x01H\x06R\x11\x65ntrypointNumGpus\x88\x01\x01\x12`\n\x14\x65ntrypoint_resources\x18\x0b \x03(\x0b\x32-.ray.rpc.JobsAPIInfo.EntrypointResourcesEntryR\x13\x65ntrypointResources\x12>\n\x19\x64river_agent_http_address\x18\x0c \x01(\tH\x07R\x16\x64riverAgentHttpAddress\x88\x01\x01\x12)\n\x0e\x64river_node_id\x18\r \x01(\tH\x08R\x0c\x64riverNodeId\x88\x01\x01\x12-\n\x10\x64river_exit_code\x18\x0e \x01(\x05H\tR\x0e\x64riverExitCode\x88\x01\x01\x12\x30\n\x11\x65ntrypoint_memory\x18\x0f \x01(\x04H\nR\x10\x65ntrypointMemory\x88\x01\x01\x1a;\n\rMetadataEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\x1a\x46\n\x18\x45ntrypointResourcesEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\x01R\x05value:\x02\x38\x01\x42\n\n\x08_messageB\r\n\x0b_error_typeB\r\n\x0b_start_timeB\x0b\n\t_end_timeB\x13\n\x11_runtime_env_jsonB\x16\n\x14_entrypoint_num_cpusB\x16\n\x14_entrypoint_num_gpusB\x1c\n\x1a_driver_agent_http_addressB\x11\n\x0f_driver_node_idB\x13\n\x11_driver_exit_codeB\x14\n\x12_entrypoint_memory\"\xd7\x06\n\x0fWorkerTableData\x12\x19\n\x08is_alive\x18\x01 \x01(\x08R\x07isAlive\x12\x37\n\x0eworker_address\x18\x02 \x01(\x0b\x32\x10.ray.rpc.AddressR\rworkerAddress\x12\x1c\n\ttimestamp\x18\x03 \x01(\x03R\ttimestamp\x12\x34\n\x0bworker_type\x18\x05 \x01(\x0e\x32\x13.ray.rpc.WorkerTypeR\nworkerType\x12I\n\x0bworker_info\x18\x06 \x03(\x0b\x32(.ray.rpc.WorkerTableData.WorkerInfoEntryR\nworkerInfo\x12M\n\x17\x63reation_task_exception\x18\x12 \x01(\x0b\x32\x15.ray.rpc.RayExceptionR\x15\x63reationTaskException\x12\x39\n\texit_type\x18\x13 \x01(\x0e\x32\x17.ray.rpc.WorkerExitTypeH\x00R\x08\x65xitType\x88\x01\x01\x12$\n\x0b\x65xit_detail\x18\x14 \x01(\tH\x01R\nexitDetail\x88\x01\x01\x12\x10\n\x03pid\x18\x15 \x01(\rR\x03pid\x12\"\n\rstart_time_ms\x18\x17 \x01(\x04R\x0bstartTimeMs\x12\x1e\n\x0b\x65nd_time_ms\x18\x18 \x01(\x04R\tendTimeMs\x12\x31\n\x15worker_launch_time_ms\x18\x19 \x01(\x04R\x12workerLaunchTimeMs\x12\x35\n\x17worker_launched_time_ms\x18\x1a \x01(\x04R\x14workerLaunchedTimeMs\x12(\n\rdebugger_port\x18\x1b \x01(\rH\x02R\x0c\x64\x65\x62uggerPort\x88\x01\x01\x12\x31\n\x12num_paused_threads\x18\x1c \x01(\rH\x03R\x10numPausedThreads\x88\x01\x01\x1a=\n\x0fWorkerInfoEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\x0cR\x05value:\x02\x38\x01\x42\x0c\n\n_exit_typeB\x0e\n\x0c_exit_detailB\x10\n\x0e_debugger_portB\x15\n\x13_num_paused_threads\"G\n\x0fWorkerDeltaData\x12\x17\n\x07node_id\x18\x01 \x01(\x0cR\x06nodeId\x12\x1b\n\tworker_id\x18\x02 \x01(\x0cR\x08workerId\"3\n\rPubSubMessage\x12\x0e\n\x02id\x18\x01 \x01(\x0cR\x02id\x12\x12\n\x04\x64\x61ta\x18\x02 \x01(\x0cR\x04\x64\x61ta\"\xe8\x02\n\x0eResourceDemand\x12\x38\n\x05shape\x18\x01 \x03(\x0b\x32\".ray.rpc.ResourceDemand.ShapeEntryR\x05shape\x12\x39\n\x19num_ready_requests_queued\x18\x02 \x01(\x04R\x16numReadyRequestsQueued\x12\x43\n\x1enum_infeasible_requests_queued\x18\x03 \x01(\x04R\x1bnumInfeasibleRequestsQueued\x12!\n\x0c\x62\x61\x63klog_size\x18\x04 \x01(\x03R\x0b\x62\x61\x63klogSize\x12?\n\x0flabel_selectors\x18\x05 \x03(\x0b\x32\x16.ray.rpc.LabelSelectorR\x0elabelSelectors\x1a\x38\n\nShapeEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\x01R\x05value:\x02\x38\x01\"R\n\x0cResourceLoad\x12\x42\n\x10resource_demands\x18\x01 \x03(\x0b\x32\x17.ray.rpc.ResourceDemandR\x0fresourceDemands\"\xfc\t\n\rResourcesData\x12\x17\n\x07node_id\x18\x01 \x01(\x0cR\x06nodeId\x12_\n\x13resources_available\x18\x02 \x03(\x0b\x32..ray.rpc.ResourcesData.ResourcesAvailableEntryR\x12resourcesAvailable\x12S\n\x0fresources_total\x18\x04 \x03(\x0b\x32*.ray.rpc.ResourcesData.ResourcesTotalEntryR\x0eresourcesTotal\x12M\n\rresource_load\x18\x05 \x03(\x0b\x32(.ray.rpc.ResourcesData.ResourceLoadEntryR\x0cresourceLoad\x12J\n\x16resource_load_by_shape\x18\x07 \x01(\x0b\x32\x15.ray.rpc.ResourceLoadR\x13resourceLoadByShape\x12\x30\n\x14node_manager_address\x18\t \x01(\tR\x12nodeManagerAddress\x12.\n\x13object_pulls_queued\x18\n \x01(\x08R\x11objectPullsQueued\x12\x63\n\x15resources_normal_task\x18\x0b \x03(\x0b\x32/.ray.rpc.ResourcesData.ResourcesNormalTaskEntryR\x13resourcesNormalTask\x12\x41\n\x1dresources_normal_task_changed\x18\x0c \x01(\x08R\x1aresourcesNormalTaskChanged\x12\x45\n\x1fresources_normal_task_timestamp\x18\r \x01(\x03R\x1cresourcesNormalTaskTimestamp\x12(\n\x10idle_duration_ms\x18\x0f \x01(\x03R\x0eidleDurationMs\x12\x1f\n\x0bis_draining\x18\x10 \x01(\x08R\nisDraining\x12\x43\n\x1e\x64raining_deadline_timestamp_ms\x18\x12 \x01(\x03R\x1b\x64rainingDeadlineTimestampMs\x12:\n\x06labels\x18\x13 \x03(\x0b\x32\".ray.rpc.ResourcesData.LabelsEntryR\x06labels\x1a\x45\n\x17ResourcesAvailableEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\x01R\x05value:\x02\x38\x01\x1a\x41\n\x13ResourcesTotalEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\x01R\x05value:\x02\x38\x01\x1a?\n\x11ResourceLoadEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\x01R\x05value:\x02\x38\x01\x1a\x46\n\x18ResourcesNormalTaskEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\x01R\x05value:\x02\x38\x01\x1a\x39\n\x0bLabelsEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01J\x04\x08\x03\x10\x04J\x04\x08\x08\x10\tJ\x04\x08\x0e\x10\x0fJ\x04\x08\x11\x10\x12\"\xe1\x01\n\x16ResourceUsageBatchData\x12,\n\x05\x62\x61tch\x18\x01 \x03(\x0b\x32\x16.ray.rpc.ResourcesDataR\x05\x62\x61tch\x12J\n\x16resource_load_by_shape\x18\x02 \x01(\x0b\x32\x15.ray.rpc.ResourceLoadR\x13resourceLoadByShape\x12M\n\x14placement_group_load\x18\x03 \x01(\x0b\x32\x1b.ray.rpc.PlacementGroupLoadR\x12placementGroupLoad\"h\n\x12PlacementGroupLoad\x12R\n\x14placement_group_data\x18\x01 \x03(\x0b\x32 .ray.rpc.PlacementGroupTableDataR\x12placementGroupData\"\xdc\x04\n\x13PlacementGroupStats\x12?\n\x1c\x63reation_request_received_ns\x18\x02 \x01(\x03R\x19\x63reationRequestReceivedNs\x12;\n\x1ascheduling_started_time_ns\x18\x03 \x01(\x03R\x17schedulingStartedTimeNs\x12\x32\n\x15scheduling_latency_us\x18\x04 \x01(\x03R\x13schedulingLatencyUs\x12\x41\n\x1e\x65nd_to_end_creation_latency_us\x18\x05 \x01(\x03R\x19\x65ndToEndCreationLatencyUs\x12-\n\x12scheduling_attempt\x18\x06 \x01(\rR\x11schedulingAttempt\x12\x33\n\x16highest_retry_delay_ms\x18\x07 \x01(\x01R\x13highestRetryDelayMs\x12W\n\x10scheduling_state\x18\x08 \x01(\x0e\x32,.ray.rpc.PlacementGroupStats.SchedulingStateR\x0fschedulingState\"\x92\x01\n\x0fSchedulingState\x12\n\n\x06QUEUED\x10\x00\x12\x0b\n\x07REMOVED\x10\x01\x12\x16\n\x12SCHEDULING_STARTED\x10\x02\x12\x10\n\x0cNO_RESOURCES\x10\x03\x12\x0e\n\nINFEASIBLE\x10\x04\x12\x1e\n\x1a\x46\x41ILED_TO_COMMIT_RESOURCES\x10\x05\x12\x0c\n\x08\x46INISHED\x10\x06\"\xf7\x06\n\x17PlacementGroupTableData\x12,\n\x12placement_group_id\x18\x01 \x01(\x0cR\x10placementGroupId\x12\x12\n\x04name\x18\x02 \x01(\tR\x04name\x12)\n\x07\x62undles\x18\x03 \x03(\x0b\x32\x0f.ray.rpc.BundleR\x07\x62undles\x12\x36\n\x08strategy\x18\x04 \x01(\x0e\x32\x1a.ray.rpc.PlacementStrategyR\x08strategy\x12J\n\x05state\x18\x05 \x01(\x0e\x32\x34.ray.rpc.PlacementGroupTableData.PlacementGroupStateR\x05state\x12$\n\x0e\x63reator_job_id\x18\x06 \x01(\x0cR\x0c\x63reatorJobId\x12(\n\x10\x63reator_actor_id\x18\x07 \x01(\x0cR\x0e\x63reatorActorId\x12(\n\x10\x63reator_job_dead\x18\x08 \x01(\x08R\x0e\x63reatorJobDead\x12,\n\x12\x63reator_actor_dead\x18\t \x01(\x08R\x10\x63reatorActorDead\x12\x1f\n\x0bis_detached\x18\n \x01(\x08R\nisDetached\x12#\n\rray_namespace\x18\x0b \x01(\tR\x0crayNamespace\x12\x32\n\x05stats\x18\x0c \x01(\x0b\x32\x1c.ray.rpc.PlacementGroupStatsR\x05stats\x12-\n\x13soft_target_node_id\x18\x0e \x01(\x0cR\x10softTargetNodeId\x12P\n%placement_group_creation_timestamp_ms\x18\x0f \x01(\x03R!placementGroupCreationTimestampMs\x12j\n3placement_group_final_bundle_placement_timestamp_ms\x18\x10 \x01(\x03R-placementGroupFinalBundlePlacementTimestampMs\"\\\n\x13PlacementGroupState\x12\x0b\n\x07PENDING\x10\x00\x12\x0c\n\x08PREPARED\x10\x01\x12\x0b\n\x07\x43REATED\x10\x02\x12\x0b\n\x07REMOVED\x10\x03\x12\x10\n\x0cRESCHEDULING\x10\x04\"\xed\x03\n\x0cJobTableData\x12\x15\n\x06job_id\x18\x01 \x01(\x0cR\x05jobId\x12\x17\n\x07is_dead\x18\x02 \x01(\x08R\x06isDead\x12\x1c\n\ttimestamp\x18\x03 \x01(\x03R\ttimestamp\x12*\n\x11\x64river_ip_address\x18\x04 \x01(\tR\x0f\x64riverIpAddress\x12\x1d\n\ndriver_pid\x18\x05 \x01(\x03R\tdriverPid\x12*\n\x06\x63onfig\x18\x06 \x01(\x0b\x32\x12.ray.rpc.JobConfigR\x06\x63onfig\x12\x1d\n\nstart_time\x18\x07 \x01(\x04R\tstartTime\x12\x19\n\x08\x65nd_time\x18\x08 \x01(\x04R\x07\x65ndTime\x12\x1e\n\nentrypoint\x18\t \x01(\tR\nentrypoint\x12\x34\n\x08job_info\x18\n \x01(\x0b\x32\x14.ray.rpc.JobsAPIInfoH\x00R\x07jobInfo\x88\x01\x01\x12-\n\x10is_running_tasks\x18\x0b \x01(\x08H\x01R\x0eisRunningTasks\x88\x01\x01\x12\x37\n\x0e\x64river_address\x18\x0c \x01(\x0b\x32\x10.ray.rpc.AddressR\rdriverAddressB\x0b\n\t_job_infoB\x13\n\x11_is_running_tasks*\xc7\x02\n\x0bTablePrefix\x12\x14\n\x10TABLE_PREFIX_MIN\x10\x00\x12\n\n\x06UNUSED\x10\x01\x12\x08\n\x04TASK\x10\x02\x12\x0f\n\x0bRAYLET_TASK\x10\x03\x12\x08\n\x04NODE\x10\x04\x12\n\n\x06OBJECT\x10\x05\x12\t\n\x05\x41\x43TOR\x10\x06\x12\x0c\n\x08\x46UNCTION\x10\x07\x12\x17\n\x13TASK_RECONSTRUCTION\x10\x08\x12\x18\n\x14RESOURCE_USAGE_BATCH\x10\t\x12\x07\n\x03JOB\x10\n\x12\x0e\n\nTASK_LEASE\x10\x0c\x12\x11\n\rNODE_RESOURCE\x10\r\x12\x10\n\x0c\x44IRECT_ACTOR\x10\x0e\x12\x0b\n\x07WORKERS\x10\x0f\x12\x1c\n\x18PLACEMENT_GROUP_SCHEDULE\x10\x10\x12\x13\n\x0fPLACEMENT_GROUP\x10\x11\x12\x06\n\x02KV\x10\x12\x12\x13\n\x0f\x41\x43TOR_TASK_SPEC\x10\x13*\xbe\x02\n\x0bTablePubsub\x12\x14\n\x10TABLE_PUBSUB_MIN\x10\x00\x12\x0e\n\nNO_PUBLISH\x10\x01\x12\x0f\n\x0bTASK_PUBSUB\x10\x02\x12\x16\n\x12RAYLET_TASK_PUBSUB\x10\x03\x12\x0f\n\x0bNODE_PUBSUB\x10\x04\x12\x11\n\rOBJECT_PUBSUB\x10\x05\x12\x10\n\x0c\x41\x43TOR_PUBSUB\x10\x06\x12\x1f\n\x1bRESOURCE_USAGE_BATCH_PUBSUB\x10\x07\x12\x15\n\x11TASK_LEASE_PUBSUB\x10\x08\x12\x0e\n\nJOB_PUBSUB\x10\t\x12\x18\n\x14NODE_RESOURCE_PUBSUB\x10\n\x12\x17\n\x13\x44IRECT_ACTOR_PUBSUB\x10\x0b\x12\x19\n\x15WORKER_FAILURE_PUBSUB\x10\x0c\x12\x14\n\x10TABLE_PUBSUB_MAX\x10\r*.\n\rGcsChangeMode\x12\x11\n\rAPPEND_OR_ADD\x10\x00\x12\n\n\x06REMOVE\x10\x01\x42\x1a\n\x18io.ray.runtime.generatedb\x06proto3')

_TABLEPREFIX = DESCRIPTOR.enum_types_by_name['TablePrefix']
TablePrefix = enum_type_wrapper.EnumTypeWrapper(_TABLEPREFIX)
_TABLEPUBSUB = DESCRIPTOR.enum_types_by_name['TablePubsub']
TablePubsub = enum_type_wrapper.EnumTypeWrapper(_TABLEPUBSUB)
_GCSCHANGEMODE = DESCRIPTOR.enum_types_by_name['GcsChangeMode']
GcsChangeMode = enum_type_wrapper.EnumTypeWrapper(_GCSCHANGEMODE)
TABLE_PREFIX_MIN = 0
UNUSED = 1
TASK = 2
RAYLET_TASK = 3
NODE = 4
OBJECT = 5
ACTOR = 6
FUNCTION = 7
TASK_RECONSTRUCTION = 8
RESOURCE_USAGE_BATCH = 9
JOB = 10
TASK_LEASE = 12
NODE_RESOURCE = 13
DIRECT_ACTOR = 14
WORKERS = 15
PLACEMENT_GROUP_SCHEDULE = 16
PLACEMENT_GROUP = 17
KV = 18
ACTOR_TASK_SPEC = 19
TABLE_PUBSUB_MIN = 0
NO_PUBLISH = 1
TASK_PUBSUB = 2
RAYLET_TASK_PUBSUB = 3
NODE_PUBSUB = 4
OBJECT_PUBSUB = 5
ACTOR_PUBSUB = 6
RESOURCE_USAGE_BATCH_PUBSUB = 7
TASK_LEASE_PUBSUB = 8
JOB_PUBSUB = 9
NODE_RESOURCE_PUBSUB = 10
DIRECT_ACTOR_PUBSUB = 11
WORKER_FAILURE_PUBSUB = 12
TABLE_PUBSUB_MAX = 13
APPEND_OR_ADD = 0
REMOVE = 1


_GCSENTRY = DESCRIPTOR.message_types_by_name['GcsEntry']
_ACTORTABLEDATA = DESCRIPTOR.message_types_by_name['ActorTableData']
_ACTORTABLEDATA_REQUIREDRESOURCESENTRY = _ACTORTABLEDATA.nested_types_by_name['RequiredResourcesEntry']
_ACTORTABLEDATA_LABELSELECTORENTRY = _ACTORTABLEDATA.nested_types_by_name['LabelSelectorEntry']
_ERRORTABLEDATA = DESCRIPTOR.message_types_by_name['ErrorTableData']
_TASKLOGINFO = DESCRIPTOR.message_types_by_name['TaskLogInfo']
_TASKSTATEUPDATE = DESCRIPTOR.message_types_by_name['TaskStateUpdate']
_TASKSTATEUPDATE_STATETSNSENTRY = _TASKSTATEUPDATE.nested_types_by_name['StateTsNsEntry']
_TASKEVENTS = DESCRIPTOR.message_types_by_name['TaskEvents']
_TASKEVENTDATA = DESCRIPTOR.message_types_by_name['TaskEventData']
_AVAILABLERESOURCES = DESCRIPTOR.message_types_by_name['AvailableResources']
_AVAILABLERESOURCES_RESOURCESAVAILABLEENTRY = _AVAILABLERESOURCES.nested_types_by_name['ResourcesAvailableEntry']
_TOTALRESOURCES = DESCRIPTOR.message_types_by_name['TotalResources']
_TOTALRESOURCES_RESOURCESTOTALENTRY = _TOTALRESOURCES.nested_types_by_name['ResourcesTotalEntry']
_NODESNAPSHOT = DESCRIPTOR.message_types_by_name['NodeSnapshot']
_GCSNODEINFO = DESCRIPTOR.message_types_by_name['GcsNodeInfo']
_GCSNODEINFO_RESOURCESTOTALENTRY = _GCSNODEINFO.nested_types_by_name['ResourcesTotalEntry']
_GCSNODEINFO_LABELSENTRY = _GCSNODEINFO.nested_types_by_name['LabelsEntry']
_GCSNODEADDRESSANDLIVENESS = DESCRIPTOR.message_types_by_name['GcsNodeAddressAndLiveness']
_JOBSAPIINFO = DESCRIPTOR.message_types_by_name['JobsAPIInfo']
_JOBSAPIINFO_METADATAENTRY = _JOBSAPIINFO.nested_types_by_name['MetadataEntry']
_JOBSAPIINFO_ENTRYPOINTRESOURCESENTRY = _JOBSAPIINFO.nested_types_by_name['EntrypointResourcesEntry']
_WORKERTABLEDATA = DESCRIPTOR.message_types_by_name['WorkerTableData']
_WORKERTABLEDATA_WORKERINFOENTRY = _WORKERTABLEDATA.nested_types_by_name['WorkerInfoEntry']
_WORKERDELTADATA = DESCRIPTOR.message_types_by_name['WorkerDeltaData']
_PUBSUBMESSAGE = DESCRIPTOR.message_types_by_name['PubSubMessage']
_RESOURCEDEMAND = DESCRIPTOR.message_types_by_name['ResourceDemand']
_RESOURCEDEMAND_SHAPEENTRY = _RESOURCEDEMAND.nested_types_by_name['ShapeEntry']
_RESOURCELOAD = DESCRIPTOR.message_types_by_name['ResourceLoad']
_RESOURCESDATA = DESCRIPTOR.message_types_by_name['ResourcesData']
_RESOURCESDATA_RESOURCESAVAILABLEENTRY = _RESOURCESDATA.nested_types_by_name['ResourcesAvailableEntry']
_RESOURCESDATA_RESOURCESTOTALENTRY = _RESOURCESDATA.nested_types_by_name['ResourcesTotalEntry']
_RESOURCESDATA_RESOURCELOADENTRY = _RESOURCESDATA.nested_types_by_name['ResourceLoadEntry']
_RESOURCESDATA_RESOURCESNORMALTASKENTRY = _RESOURCESDATA.nested_types_by_name['ResourcesNormalTaskEntry']
_RESOURCESDATA_LABELSENTRY = _RESOURCESDATA.nested_types_by_name['LabelsEntry']
_RESOURCEUSAGEBATCHDATA = DESCRIPTOR.message_types_by_name['ResourceUsageBatchData']
_PLACEMENTGROUPLOAD = DESCRIPTOR.message_types_by_name['PlacementGroupLoad']
_PLACEMENTGROUPSTATS = DESCRIPTOR.message_types_by_name['PlacementGroupStats']
_PLACEMENTGROUPTABLEDATA = DESCRIPTOR.message_types_by_name['PlacementGroupTableData']
_JOBTABLEDATA = DESCRIPTOR.message_types_by_name['JobTableData']
_ACTORTABLEDATA_ACTORSTATE = _ACTORTABLEDATA.enum_types_by_name['ActorState']
_NODESNAPSHOT_STATE = _NODESNAPSHOT.enum_types_by_name['State']
_GCSNODEINFO_GCSNODESTATE = _GCSNODEINFO.enum_types_by_name['GcsNodeState']
_PLACEMENTGROUPSTATS_SCHEDULINGSTATE = _PLACEMENTGROUPSTATS.enum_types_by_name['SchedulingState']
_PLACEMENTGROUPTABLEDATA_PLACEMENTGROUPSTATE = _PLACEMENTGROUPTABLEDATA.enum_types_by_name['PlacementGroupState']
GcsEntry = _reflection.GeneratedProtocolMessageType('GcsEntry', (_message.Message,), {
  'DESCRIPTOR' : _GCSENTRY,
  '__module__' : 'src.ray.protobuf.gcs_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.GcsEntry)
  })
_sym_db.RegisterMessage(GcsEntry)

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

  'RequiredResourcesEntry' : _reflection.GeneratedProtocolMessageType('RequiredResourcesEntry', (_message.Message,), {
    'DESCRIPTOR' : _ACTORTABLEDATA_REQUIREDRESOURCESENTRY,
    '__module__' : 'src.ray.protobuf.gcs_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.ActorTableData.RequiredResourcesEntry)
    })
  ,

  'LabelSelectorEntry' : _reflection.GeneratedProtocolMessageType('LabelSelectorEntry', (_message.Message,), {
    'DESCRIPTOR' : _ACTORTABLEDATA_LABELSELECTORENTRY,
    '__module__' : 'src.ray.protobuf.gcs_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.ActorTableData.LabelSelectorEntry)
    })
  ,
  'DESCRIPTOR' : _ACTORTABLEDATA,
  '__module__' : 'src.ray.protobuf.gcs_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.ActorTableData)
  })
_sym_db.RegisterMessage(ActorTableData)
_sym_db.RegisterMessage(ActorTableData.RequiredResourcesEntry)
_sym_db.RegisterMessage(ActorTableData.LabelSelectorEntry)

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

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

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

  'StateTsNsEntry' : _reflection.GeneratedProtocolMessageType('StateTsNsEntry', (_message.Message,), {
    'DESCRIPTOR' : _TASKSTATEUPDATE_STATETSNSENTRY,
    '__module__' : 'src.ray.protobuf.gcs_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.TaskStateUpdate.StateTsNsEntry)
    })
  ,
  'DESCRIPTOR' : _TASKSTATEUPDATE,
  '__module__' : 'src.ray.protobuf.gcs_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.TaskStateUpdate)
  })
_sym_db.RegisterMessage(TaskStateUpdate)
_sym_db.RegisterMessage(TaskStateUpdate.StateTsNsEntry)

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

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

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

  'ResourcesAvailableEntry' : _reflection.GeneratedProtocolMessageType('ResourcesAvailableEntry', (_message.Message,), {
    'DESCRIPTOR' : _AVAILABLERESOURCES_RESOURCESAVAILABLEENTRY,
    '__module__' : 'src.ray.protobuf.gcs_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.AvailableResources.ResourcesAvailableEntry)
    })
  ,
  'DESCRIPTOR' : _AVAILABLERESOURCES,
  '__module__' : 'src.ray.protobuf.gcs_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.AvailableResources)
  })
_sym_db.RegisterMessage(AvailableResources)
_sym_db.RegisterMessage(AvailableResources.ResourcesAvailableEntry)

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

  'ResourcesTotalEntry' : _reflection.GeneratedProtocolMessageType('ResourcesTotalEntry', (_message.Message,), {
    'DESCRIPTOR' : _TOTALRESOURCES_RESOURCESTOTALENTRY,
    '__module__' : 'src.ray.protobuf.gcs_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.TotalResources.ResourcesTotalEntry)
    })
  ,
  'DESCRIPTOR' : _TOTALRESOURCES,
  '__module__' : 'src.ray.protobuf.gcs_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.TotalResources)
  })
_sym_db.RegisterMessage(TotalResources)
_sym_db.RegisterMessage(TotalResources.ResourcesTotalEntry)

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

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

  'ResourcesTotalEntry' : _reflection.GeneratedProtocolMessageType('ResourcesTotalEntry', (_message.Message,), {
    'DESCRIPTOR' : _GCSNODEINFO_RESOURCESTOTALENTRY,
    '__module__' : 'src.ray.protobuf.gcs_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.GcsNodeInfo.ResourcesTotalEntry)
    })
  ,

  'LabelsEntry' : _reflection.GeneratedProtocolMessageType('LabelsEntry', (_message.Message,), {
    'DESCRIPTOR' : _GCSNODEINFO_LABELSENTRY,
    '__module__' : 'src.ray.protobuf.gcs_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.GcsNodeInfo.LabelsEntry)
    })
  ,
  'DESCRIPTOR' : _GCSNODEINFO,
  '__module__' : 'src.ray.protobuf.gcs_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.GcsNodeInfo)
  })
_sym_db.RegisterMessage(GcsNodeInfo)
_sym_db.RegisterMessage(GcsNodeInfo.ResourcesTotalEntry)
_sym_db.RegisterMessage(GcsNodeInfo.LabelsEntry)

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

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

  'MetadataEntry' : _reflection.GeneratedProtocolMessageType('MetadataEntry', (_message.Message,), {
    'DESCRIPTOR' : _JOBSAPIINFO_METADATAENTRY,
    '__module__' : 'src.ray.protobuf.gcs_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.JobsAPIInfo.MetadataEntry)
    })
  ,

  'EntrypointResourcesEntry' : _reflection.GeneratedProtocolMessageType('EntrypointResourcesEntry', (_message.Message,), {
    'DESCRIPTOR' : _JOBSAPIINFO_ENTRYPOINTRESOURCESENTRY,
    '__module__' : 'src.ray.protobuf.gcs_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.JobsAPIInfo.EntrypointResourcesEntry)
    })
  ,
  'DESCRIPTOR' : _JOBSAPIINFO,
  '__module__' : 'src.ray.protobuf.gcs_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.JobsAPIInfo)
  })
_sym_db.RegisterMessage(JobsAPIInfo)
_sym_db.RegisterMessage(JobsAPIInfo.MetadataEntry)
_sym_db.RegisterMessage(JobsAPIInfo.EntrypointResourcesEntry)

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

  'WorkerInfoEntry' : _reflection.GeneratedProtocolMessageType('WorkerInfoEntry', (_message.Message,), {
    'DESCRIPTOR' : _WORKERTABLEDATA_WORKERINFOENTRY,
    '__module__' : 'src.ray.protobuf.gcs_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.WorkerTableData.WorkerInfoEntry)
    })
  ,
  'DESCRIPTOR' : _WORKERTABLEDATA,
  '__module__' : 'src.ray.protobuf.gcs_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.WorkerTableData)
  })
_sym_db.RegisterMessage(WorkerTableData)
_sym_db.RegisterMessage(WorkerTableData.WorkerInfoEntry)

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

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

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

  'ShapeEntry' : _reflection.GeneratedProtocolMessageType('ShapeEntry', (_message.Message,), {
    'DESCRIPTOR' : _RESOURCEDEMAND_SHAPEENTRY,
    '__module__' : 'src.ray.protobuf.gcs_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.ResourceDemand.ShapeEntry)
    })
  ,
  'DESCRIPTOR' : _RESOURCEDEMAND,
  '__module__' : 'src.ray.protobuf.gcs_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.ResourceDemand)
  })
_sym_db.RegisterMessage(ResourceDemand)
_sym_db.RegisterMessage(ResourceDemand.ShapeEntry)

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

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

  'ResourcesAvailableEntry' : _reflection.GeneratedProtocolMessageType('ResourcesAvailableEntry', (_message.Message,), {
    'DESCRIPTOR' : _RESOURCESDATA_RESOURCESAVAILABLEENTRY,
    '__module__' : 'src.ray.protobuf.gcs_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.ResourcesData.ResourcesAvailableEntry)
    })
  ,

  'ResourcesTotalEntry' : _reflection.GeneratedProtocolMessageType('ResourcesTotalEntry', (_message.Message,), {
    'DESCRIPTOR' : _RESOURCESDATA_RESOURCESTOTALENTRY,
    '__module__' : 'src.ray.protobuf.gcs_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.ResourcesData.ResourcesTotalEntry)
    })
  ,

  'ResourceLoadEntry' : _reflection.GeneratedProtocolMessageType('ResourceLoadEntry', (_message.Message,), {
    'DESCRIPTOR' : _RESOURCESDATA_RESOURCELOADENTRY,
    '__module__' : 'src.ray.protobuf.gcs_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.ResourcesData.ResourceLoadEntry)
    })
  ,

  'ResourcesNormalTaskEntry' : _reflection.GeneratedProtocolMessageType('ResourcesNormalTaskEntry', (_message.Message,), {
    'DESCRIPTOR' : _RESOURCESDATA_RESOURCESNORMALTASKENTRY,
    '__module__' : 'src.ray.protobuf.gcs_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.ResourcesData.ResourcesNormalTaskEntry)
    })
  ,

  'LabelsEntry' : _reflection.GeneratedProtocolMessageType('LabelsEntry', (_message.Message,), {
    'DESCRIPTOR' : _RESOURCESDATA_LABELSENTRY,
    '__module__' : 'src.ray.protobuf.gcs_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.ResourcesData.LabelsEntry)
    })
  ,
  'DESCRIPTOR' : _RESOURCESDATA,
  '__module__' : 'src.ray.protobuf.gcs_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.ResourcesData)
  })
_sym_db.RegisterMessage(ResourcesData)
_sym_db.RegisterMessage(ResourcesData.ResourcesAvailableEntry)
_sym_db.RegisterMessage(ResourcesData.ResourcesTotalEntry)
_sym_db.RegisterMessage(ResourcesData.ResourceLoadEntry)
_sym_db.RegisterMessage(ResourcesData.ResourcesNormalTaskEntry)
_sym_db.RegisterMessage(ResourcesData.LabelsEntry)

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

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

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

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

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

if _descriptor._USE_C_DESCRIPTORS == False:

  DESCRIPTOR._options = None
  DESCRIPTOR._serialized_options = b'\n\030io.ray.runtime.generated'
  _ACTORTABLEDATA_REQUIREDRESOURCESENTRY._options = None
  _ACTORTABLEDATA_REQUIREDRESOURCESENTRY._serialized_options = b'8\001'
  _ACTORTABLEDATA_LABELSELECTORENTRY._options = None
  _ACTORTABLEDATA_LABELSELECTORENTRY._serialized_options = b'8\001'
  _TASKSTATEUPDATE_STATETSNSENTRY._options = None
  _TASKSTATEUPDATE_STATETSNSENTRY._serialized_options = b'8\001'
  _AVAILABLERESOURCES_RESOURCESAVAILABLEENTRY._options = None
  _AVAILABLERESOURCES_RESOURCESAVAILABLEENTRY._serialized_options = b'8\001'
  _TOTALRESOURCES_RESOURCESTOTALENTRY._options = None
  _TOTALRESOURCES_RESOURCESTOTALENTRY._serialized_options = b'8\001'
  _GCSNODEINFO_RESOURCESTOTALENTRY._options = None
  _GCSNODEINFO_RESOURCESTOTALENTRY._serialized_options = b'8\001'
  _GCSNODEINFO_LABELSENTRY._options = None
  _GCSNODEINFO_LABELSENTRY._serialized_options = b'8\001'
  _JOBSAPIINFO_METADATAENTRY._options = None
  _JOBSAPIINFO_METADATAENTRY._serialized_options = b'8\001'
  _JOBSAPIINFO_ENTRYPOINTRESOURCESENTRY._options = None
  _JOBSAPIINFO_ENTRYPOINTRESOURCESENTRY._serialized_options = b'8\001'
  _WORKERTABLEDATA_WORKERINFOENTRY._options = None
  _WORKERTABLEDATA_WORKERINFOENTRY._serialized_options = b'8\001'
  _RESOURCEDEMAND_SHAPEENTRY._options = None
  _RESOURCEDEMAND_SHAPEENTRY._serialized_options = b'8\001'
  _RESOURCESDATA_RESOURCESAVAILABLEENTRY._options = None
  _RESOURCESDATA_RESOURCESAVAILABLEENTRY._serialized_options = b'8\001'
  _RESOURCESDATA_RESOURCESTOTALENTRY._options = None
  _RESOURCESDATA_RESOURCESTOTALENTRY._serialized_options = b'8\001'
  _RESOURCESDATA_RESOURCELOADENTRY._options = None
  _RESOURCESDATA_RESOURCELOADENTRY._serialized_options = b'8\001'
  _RESOURCESDATA_RESOURCESNORMALTASKENTRY._options = None
  _RESOURCESDATA_RESOURCESNORMALTASKENTRY._serialized_options = b'8\001'
  _RESOURCESDATA_LABELSENTRY._options = None
  _RESOURCESDATA_LABELSENTRY._serialized_options = b'8\001'
  _TABLEPREFIX._serialized_start=11689
  _TABLEPREFIX._serialized_end=12016
  _TABLEPUBSUB._serialized_start=12019
  _TABLEPUBSUB._serialized_end=12337
  _GCSCHANGEMODE._serialized_start=12339
  _GCSCHANGEMODE._serialized_end=12385
  _GCSENTRY._serialized_start=109
  _GCSENTRY._serialized_end=218
  _ACTORTABLEDATA._serialized_start=221
  _ACTORTABLEDATA._serialized_end=1835
  _ACTORTABLEDATA_REQUIREDRESOURCESENTRY._serialized_start=1553
  _ACTORTABLEDATA_REQUIREDRESOURCESENTRY._serialized_end=1621
  _ACTORTABLEDATA_LABELSELECTORENTRY._serialized_start=1623
  _ACTORTABLEDATA_LABELSELECTORENTRY._serialized_end=1687
  _ACTORTABLEDATA_ACTORSTATE._serialized_start=1689
  _ACTORTABLEDATA_ACTORSTATE._serialized_end=1786
  _ERRORTABLEDATA._serialized_start=1837
  _ERRORTABLEDATA._serialized_end=1963
  _TASKLOGINFO._serialized_start=1966
  _TASKLOGINFO._serialized_end=2303
  _TASKSTATEUPDATE._serialized_start=2306
  _TASKSTATEUPDATE._serialized_end=2893
  _TASKSTATEUPDATE_STATETSNSENTRY._serialized_start=2716
  _TASKSTATEUPDATE_STATETSNSENTRY._serialized_end=2776
  _TASKEVENTS._serialized_start=2896
  _TASKEVENTS._serialized_end=3240
  _TASKEVENTDATA._serialized_start=3243
  _TASKEVENTDATA._serialized_end=3475
  _AVAILABLERESOURCES._serialized_start=3478
  _AVAILABLERESOURCES._serialized_end=3696
  _AVAILABLERESOURCES_RESOURCESAVAILABLEENTRY._serialized_start=3627
  _AVAILABLERESOURCES_RESOURCESAVAILABLEENTRY._serialized_end=3696
  _TOTALRESOURCES._serialized_start=3699
  _TOTALRESOURCES._serialized_end=3893
  _TOTALRESOURCES_RESOURCESTOTALENTRY._serialized_start=3828
  _TOTALRESOURCES_RESOURCESTOTALENTRY._serialized_end=3893
  _NODESNAPSHOT._serialized_start=3896
  _NODESNAPSHOT._serialized_end=4100
  _NODESNAPSHOT_STATE._serialized_start=4042
  _NODESNAPSHOT_STATE._serialized_end=4100
  _GCSNODEINFO._serialized_start=4103
  _GCSNODEINFO._serialized_end=5265
  _GCSNODEINFO_RESOURCESTOTALENTRY._serialized_start=3828
  _GCSNODEINFO_RESOURCESTOTALENTRY._serialized_end=3893
  _GCSNODEINFO_LABELSENTRY._serialized_start=5171
  _GCSNODEINFO_LABELSENTRY._serialized_end=5228
  _GCSNODEINFO_GCSNODESTATE._serialized_start=5230
  _GCSNODEINFO_GCSNODESTATE._serialized_end=5265
  _GCSNODEADDRESSANDLIVENESS._serialized_start=5268
  _GCSNODEADDRESSANDLIVENESS._serialized_end=5574
  _JOBSAPIINFO._serialized_start=5577
  _JOBSAPIINFO._serialized_end=6649
  _JOBSAPIINFO_METADATAENTRY._serialized_start=6302
  _JOBSAPIINFO_METADATAENTRY._serialized_end=6361
  _JOBSAPIINFO_ENTRYPOINTRESOURCESENTRY._serialized_start=6363
  _JOBSAPIINFO_ENTRYPOINTRESOURCESENTRY._serialized_end=6433
  _WORKERTABLEDATA._serialized_start=6652
  _WORKERTABLEDATA._serialized_end=7507
  _WORKERTABLEDATA_WORKERINFOENTRY._serialized_start=7375
  _WORKERTABLEDATA_WORKERINFOENTRY._serialized_end=7436
  _WORKERDELTADATA._serialized_start=7509
  _WORKERDELTADATA._serialized_end=7580
  _PUBSUBMESSAGE._serialized_start=7582
  _PUBSUBMESSAGE._serialized_end=7633
  _RESOURCEDEMAND._serialized_start=7636
  _RESOURCEDEMAND._serialized_end=7996
  _RESOURCEDEMAND_SHAPEENTRY._serialized_start=7940
  _RESOURCEDEMAND_SHAPEENTRY._serialized_end=7996
  _RESOURCELOAD._serialized_start=7998
  _RESOURCELOAD._serialized_end=8080
  _RESOURCESDATA._serialized_start=8083
  _RESOURCESDATA._serialized_end=9359
  _RESOURCESDATA_RESOURCESAVAILABLEENTRY._serialized_start=3627
  _RESOURCESDATA_RESOURCESAVAILABLEENTRY._serialized_end=3696
  _RESOURCESDATA_RESOURCESTOTALENTRY._serialized_start=3828
  _RESOURCESDATA_RESOURCESTOTALENTRY._serialized_end=3893
  _RESOURCESDATA_RESOURCELOADENTRY._serialized_start=9141
  _RESOURCESDATA_RESOURCELOADENTRY._serialized_end=9204
  _RESOURCESDATA_RESOURCESNORMALTASKENTRY._serialized_start=9206
  _RESOURCESDATA_RESOURCESNORMALTASKENTRY._serialized_end=9276
  _RESOURCESDATA_LABELSENTRY._serialized_start=5171
  _RESOURCESDATA_LABELSENTRY._serialized_end=5228
  _RESOURCEUSAGEBATCHDATA._serialized_start=9362
  _RESOURCEUSAGEBATCHDATA._serialized_end=9587
  _PLACEMENTGROUPLOAD._serialized_start=9589
  _PLACEMENTGROUPLOAD._serialized_end=9693
  _PLACEMENTGROUPSTATS._serialized_start=9696
  _PLACEMENTGROUPSTATS._serialized_end=10300
  _PLACEMENTGROUPSTATS_SCHEDULINGSTATE._serialized_start=10154
  _PLACEMENTGROUPSTATS_SCHEDULINGSTATE._serialized_end=10300
  _PLACEMENTGROUPTABLEDATA._serialized_start=10303
  _PLACEMENTGROUPTABLEDATA._serialized_end=11190
  _PLACEMENTGROUPTABLEDATA_PLACEMENTGROUPSTATE._serialized_start=11098
  _PLACEMENTGROUPTABLEDATA_PLACEMENTGROUPSTATE._serialized_end=11190
  _JOBTABLEDATA._serialized_start=11193
  _JOBTABLEDATA._serialized_end=11686
# @@protoc_insertion_point(module_scope)