# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler.  DO NOT EDIT!
# source: src/ray/protobuf/gcs_service.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 gcs_pb2 as src_dot_ray_dot_protobuf_dot_gcs__pb2
from . import pubsub_pb2 as src_dot_ray_dot_protobuf_dot_pubsub__pb2
from . import events_event_aggregator_service_pb2 as src_dot_ray_dot_protobuf_dot_events__event__aggregator__service__pb2


DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\"src/ray/protobuf/gcs_service.proto\x12\x07ray.rpc\x1a\x1dsrc/ray/protobuf/common.proto\x1a\x1asrc/ray/protobuf/gcs.proto\x1a\x1dsrc/ray/protobuf/pubsub.proto\x1a\x36src/ray/protobuf/events_event_aggregator_service.proto\":\n\rAddJobRequest\x12)\n\x04\x64\x61ta\x18\x01 \x01(\x0b\x32\x15.ray.rpc.JobTableDataR\x04\x64\x61ta\"9\n\x0b\x41\x64\x64JobReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\"/\n\x16MarkJobFinishedRequest\x12\x15\n\x06job_id\x18\x01 \x01(\x0cR\x05jobId\"B\n\x14MarkJobFinishedReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\"\xd9\x02\n\x14GetAllJobInfoRequest\x12\x19\n\x05limit\x18\x01 \x01(\x05H\x00R\x05limit\x88\x01\x01\x12\x34\n\x14job_or_submission_id\x18\x02 \x01(\tH\x01R\x11jobOrSubmissionId\x88\x01\x01\x12G\n\x1eskip_submission_job_info_field\x18\x03 \x01(\x08H\x02R\x1askipSubmissionJobInfoField\x88\x01\x01\x12\x41\n\x1bskip_is_running_tasks_field\x18\x04 \x01(\x08H\x03R\x17skipIsRunningTasksField\x88\x01\x01\x42\x08\n\x06_limitB\x17\n\x15_job_or_submission_idB!\n\x1f_skip_submission_job_info_fieldB\x1e\n\x1c_skip_is_running_tasks_field\"{\n\x12GetAllJobInfoReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12\x39\n\rjob_info_list\x18\x02 \x03(\x0b\x32\x15.ray.rpc.JobTableDataR\x0bjobInfoList\"M\n\x15ReportJobErrorRequest\x12\x34\n\tjob_error\x18\x01 \x01(\x0b\x32\x17.ray.rpc.ErrorTableDataR\x08jobError\"A\n\x13ReportJobErrorReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\"\x15\n\x13GetNextJobIDRequest\"V\n\x11GetNextJobIDReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12\x15\n\x06job_id\x18\x02 \x01(\x05R\x05jobId\"D\n\x13GetActorInfoRequest\x12\x19\n\x08\x61\x63tor_id\x18\x01 \x01(\x0cR\x07\x61\x63torId\x12\x12\n\x04name\x18\x02 \x01(\tR\x04name\"\x82\x01\n\x11GetActorInfoReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12\x41\n\x10\x61\x63tor_table_data\x18\x02 \x01(\x0b\x32\x17.ray.rpc.ActorTableDataR\x0e\x61\x63torTableData\"S\n\x18GetNamedActorInfoRequest\x12\x12\n\x04name\x18\x01 \x01(\tR\x04name\x12#\n\rray_namespace\x18\x02 \x01(\tR\x0crayNamespace\"\xb7\x01\n\x16GetNamedActorInfoReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12\x41\n\x10\x61\x63tor_table_data\x18\x02 \x01(\x0b\x32\x17.ray.rpc.ActorTableDataR\x0e\x61\x63torTableData\x12.\n\ttask_spec\x18\x03 \x01(\x0b\x32\x11.ray.rpc.TaskSpecR\x08taskSpec\"d\n\x16ListNamedActorsRequest\x12%\n\x0e\x61ll_namespaces\x18\x01 \x01(\x08R\rallNamespaces\x12#\n\rray_namespace\x18\x02 \x01(\tR\x0crayNamespace\"\x87\x01\n\x14ListNamedActorsReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12\x43\n\x11named_actors_list\x18\x02 \x03(\x0b\x32\x17.ray.rpc.NamedActorInfoR\x0fnamedActorsList\"\xe0\x02\n\x16GetAllActorInfoRequest\x12$\n\x0eshow_dead_jobs\x18\x01 \x01(\x08R\x0cshowDeadJobs\x12\x19\n\x05limit\x18\x02 \x01(\x03H\x00R\x05limit\x88\x01\x01\x12\x46\n\x07\x66ilters\x18\x03 \x01(\x0b\x32\'.ray.rpc.GetAllActorInfoRequest.FiltersH\x01R\x07\x66ilters\x88\x01\x01\x1a\xa6\x01\n\x07\x46ilters\x12\x1e\n\x08\x61\x63tor_id\x18\x01 \x01(\x0cH\x00R\x07\x61\x63torId\x88\x01\x01\x12\x1a\n\x06job_id\x18\x02 \x01(\x0cH\x01R\x05jobId\x88\x01\x01\x12=\n\x05state\x18\x03 \x01(\x0e\x32\".ray.rpc.ActorTableData.ActorStateH\x02R\x05state\x88\x01\x01\x42\x0b\n\t_actor_idB\t\n\x07_job_idB\x08\n\x06_stateB\x08\n\x06_limitB\n\n\x08_filters\"\xbe\x01\n\x14GetAllActorInfoReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12\x41\n\x10\x61\x63tor_table_data\x18\x02 \x03(\x0b\x32\x17.ray.rpc.ActorTableDataR\x0e\x61\x63torTableData\x12\x14\n\x05total\x18\x03 \x01(\x03R\x05total\x12!\n\x0cnum_filtered\x18\x04 \x01(\x03R\x0bnumFiltered\"q\n\x16KillActorViaGcsRequest\x12\x19\n\x08\x61\x63tor_id\x18\x01 \x01(\x0cR\x07\x61\x63torId\x12\x1d\n\nforce_kill\x18\x02 \x01(\x08R\tforceKill\x12\x1d\n\nno_restart\x18\x03 \x01(\x08R\tnoRestart\"B\n\x14KillActorViaGcsReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\"\x94\x01\n\x1cReportActorOutOfScopeRequest\x12\x19\n\x08\x61\x63tor_id\x18\x01 \x01(\x0cR\x07\x61\x63torId\x12Y\n*num_restarts_due_to_lineage_reconstruction\x18\x02 \x01(\x04R%numRestartsDueToLineageReconstruction\"H\n\x1aReportActorOutOfScopeReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\"\x15\n\x13GetClusterIdRequest\"^\n\x11GetClusterIdReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12\x1d\n\ncluster_id\x18\x02 \x01(\x0cR\tclusterId\"H\n\x13RegisterNodeRequest\x12\x31\n\tnode_info\x18\x01 \x01(\x0b\x32\x14.ray.rpc.GcsNodeInfoR\x08nodeInfo\"?\n\x11RegisterNodeReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\"p\n\x15UnregisterNodeRequest\x12\x17\n\x07node_id\x18\x01 \x01(\x0cR\x06nodeId\x12>\n\x0fnode_death_info\x18\x02 \x01(\x0b\x32\x16.ray.rpc.NodeDeathInfoR\rnodeDeathInfo\"A\n\x13UnregisterNodeReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\"\xf2\x02\n\x15GetAllNodeInfoRequest\x12\x19\n\x05limit\x18\x01 \x01(\x03H\x00R\x05limit\x88\x01\x01\x12R\n\x0enode_selectors\x18\x02 \x03(\x0b\x32+.ray.rpc.GetAllNodeInfoRequest.NodeSelectorR\rnodeSelectors\x12I\n\x0cstate_filter\x18\x03 \x01(\x0e\x32!.ray.rpc.GcsNodeInfo.GcsNodeStateH\x01R\x0bstateFilter\x88\x01\x01\x1a\x83\x01\n\x0cNodeSelector\x12\x19\n\x07node_id\x18\x01 \x01(\x0cH\x00R\x06nodeId\x12\x1d\n\tnode_name\x18\x02 \x01(\tH\x00R\x08nodeName\x12(\n\x0fnode_ip_address\x18\x03 \x01(\tH\x00R\rnodeIpAddressB\x0f\n\rnode_selectorB\x08\n\x06_limitB\x0f\n\r_state_filter\"\xb6\x01\n\x13GetAllNodeInfoReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12:\n\x0enode_info_list\x18\x02 \x03(\x0b\x32\x14.ray.rpc.GcsNodeInfoR\x0cnodeInfoList\x12\x14\n\x05total\x18\x03 \x01(\x03R\x05total\x12!\n\x0cnum_filtered\x18\x04 \x01(\x03R\x0bnumFiltered\"\xc1\x01\n#GetAllNodeAddressAndLivenessRequest\x12\x19\n\x08node_ids\x18\x01 \x03(\x0cR\x07nodeIds\x12\x19\n\x05limit\x18\x02 \x01(\x03H\x00R\x05limit\x88\x01\x01\x12I\n\x0cstate_filter\x18\x03 \x01(\x0e\x32!.ray.rpc.GcsNodeInfo.GcsNodeStateH\x01R\x0bstateFilter\x88\x01\x01\x42\x08\n\x06_limitB\x0f\n\r_state_filter\"\x99\x01\n!GetAllNodeAddressAndLivenessReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12H\n\x0enode_info_list\x18\x02 \x03(\x0b\x32\".ray.rpc.GcsNodeAddressAndLivenessR\x0cnodeInfoList\".\n\x11\x43heckAliveRequest\x12\x19\n\x08node_ids\x18\x01 \x03(\x0cR\x07nodeIds\"\x81\x01\n\x0f\x43heckAliveReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12\x1f\n\x0bray_version\x18\x02 \x01(\tR\nrayVersion\x12!\n\x0craylet_alive\x18\x03 \x03(\x08R\x0brayletAlive\"\x1a\n\x18GetInternalConfigRequest\"\\\n\x16GetInternalConfigReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12\x16\n\x06\x63onfig\x18\x02 \x01(\tR\x06\x63onfig\"B\n\x14\x44\x65leteResourcesReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\"!\n\x1fGetAllAvailableResourcesRequest\"\x8f\x01\n\x1dGetAllAvailableResourcesReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12\x42\n\x0eresources_list\x18\x02 \x03(\x0b\x32\x1b.ray.rpc.AvailableResourcesR\rresourcesList\"\x1d\n\x1bGetAllTotalResourcesRequest\"\x87\x01\n\x19GetAllTotalResourcesReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12>\n\x0eresources_list\x18\x02 \x03(\x0b\x32\x17.ray.rpc.TotalResourcesR\rresourcesList\"]\n\x1aReportWorkerFailureRequest\x12?\n\x0eworker_failure\x18\x01 \x01(\x0b\x32\x18.ray.rpc.WorkerTableDataR\rworkerFailure\"F\n\x18ReportWorkerFailureReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\"3\n\x14GetWorkerInfoRequest\x12\x1b\n\tworker_id\x18\x01 \x01(\x0cR\x08workerId\"\x86\x01\n\x12GetWorkerInfoReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12\x44\n\x11worker_table_data\x18\x02 \x01(\x0b\x32\x18.ray.rpc.WorkerTableDataR\x0fworkerTableData\"\x9c\x02\n\x17GetAllWorkerInfoRequest\x12\x19\n\x05limit\x18\x01 \x01(\x03H\x00R\x05limit\x88\x01\x01\x12G\n\x07\x66ilters\x18\x02 \x01(\x0b\x32(.ray.rpc.GetAllWorkerInfoRequest.FiltersH\x01R\x07\x66ilters\x88\x01\x01\x1a\x86\x01\n\x07\x46ilters\x12\x35\n\x14\x65xist_paused_threads\x18\x01 \x01(\x08H\x00R\x12\x65xistPausedThreads\x88\x01\x01\x12\x1e\n\x08is_alive\x18\x02 \x01(\x08H\x01R\x07isAlive\x88\x01\x01\x42\x17\n\x15_exist_paused_threadsB\x0b\n\t_is_aliveB\x08\n\x06_limitB\n\n\x08_filters\"\xc2\x01\n\x15GetAllWorkerInfoReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12\x44\n\x11worker_table_data\x18\x02 \x03(\x0b\x32\x18.ray.rpc.WorkerTableDataR\x0fworkerTableData\x12\x14\n\x05total\x18\x03 \x01(\x03R\x05total\x12!\n\x0cnum_filtered\x18\x04 \x01(\x03R\x0bnumFiltered\"Q\n\x14\x41\x64\x64WorkerInfoRequest\x12\x39\n\x0bworker_data\x18\x01 \x01(\x0b\x32\x18.ray.rpc.WorkerTableDataR\nworkerData\"@\n\x12\x41\x64\x64WorkerInfoReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\"c\n\x1fUpdateWorkerDebuggerPortRequest\x12\x1b\n\tworker_id\x18\x01 \x01(\x0cR\x08workerId\x12#\n\rdebugger_port\x18\x02 \x01(\rR\x0c\x64\x65\x62uggerPort\"K\n\x1dUpdateWorkerDebuggerPortReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\"{\n#UpdateWorkerNumPausedThreadsRequest\x12\x1b\n\tworker_id\x18\x01 \x01(\x0cR\x08workerId\x12\x37\n\x18num_paused_threads_delta\x18\x02 \x01(\x05R\x15numPausedThreadsDelta\"O\n!UpdateWorkerNumPausedThreadsReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\"D\n\x12\x43reateActorRequest\x12.\n\ttask_spec\x18\x01 \x01(\x0b\x32\x11.ray.rpc.TaskSpecR\x08taskSpec\"\x89\x02\n\x10\x43reateActorReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12\x35\n\ractor_address\x18\x02 \x01(\x0b\x32\x10.ray.rpc.AddressR\x0c\x61\x63torAddress\x12\x42\n\rborrowed_refs\x18\x03 \x03(\x0b\x32\x1d.ray.rpc.ObjectReferenceCountR\x0c\x62orrowedRefs\x12>\n\x0b\x64\x65\x61th_cause\x18\x04 \x01(\x0b\x32\x18.ray.rpc.ActorDeathCauseH\x00R\ndeathCause\x88\x01\x01\x42\x0e\n\x0c_death_cause\"F\n\x14RegisterActorRequest\x12.\n\ttask_spec\x18\x01 \x01(\x0b\x32\x11.ray.rpc.TaskSpecR\x08taskSpec\"@\n\x12RegisterActorReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\"\xa3\x01\n+RestartActorForLineageReconstructionRequest\x12\x19\n\x08\x61\x63tor_id\x18\x01 \x01(\x0cR\x07\x61\x63torId\x12Y\n*num_restarts_due_to_lineage_reconstruction\x18\x02 \x01(\x04R%numRestartsDueToLineageReconstruction\"W\n)RestartActorForLineageReconstructionReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\"l\n\x1b\x43reatePlacementGroupRequest\x12M\n\x14placement_group_spec\x18\x01 \x01(\x0b\x32\x1b.ray.rpc.PlacementGroupSpecR\x12placementGroupSpec\"G\n\x19\x43reatePlacementGroupReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\"K\n\x1bRemovePlacementGroupRequest\x12,\n\x12placement_group_id\x18\x01 \x01(\x0cR\x10placementGroupId\"G\n\x19RemovePlacementGroupReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\"H\n\x18GetPlacementGroupRequest\x12,\n\x12placement_group_id\x18\x01 \x01(\x0cR\x10placementGroupId\"\xa3\x01\n\x16GetPlacementGroupReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12]\n\x1aplacement_group_table_data\x18\x02 \x01(\x0b\x32 .ray.rpc.PlacementGroupTableDataR\x17placementGroupTableData\"B\n\x1bGetAllPlacementGroupRequest\x12\x19\n\x05limit\x18\x01 \x01(\x03H\x00R\x05limit\x88\x01\x01\x42\x08\n\x06_limit\"\xbc\x01\n\x19GetAllPlacementGroupReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12]\n\x1aplacement_group_table_data\x18\x02 \x03(\x0b\x32 .ray.rpc.PlacementGroupTableDataR\x17placementGroupTableData\x12\x14\n\x05total\x18\x03 \x01(\x03R\x05total\"S\n#WaitPlacementGroupUntilReadyRequest\x12,\n\x12placement_group_id\x18\x01 \x01(\x0cR\x10placementGroupId\"O\n!WaitPlacementGroupUntilReadyReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\"X\n\x1dGetNamedPlacementGroupRequest\x12\x12\n\x04name\x18\x01 \x01(\tR\x04name\x12#\n\rray_namespace\x18\x02 \x01(\tR\x0crayNamespace\"\xa8\x01\n\x1bGetNamedPlacementGroupReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12]\n\x1aplacement_group_table_data\x18\x02 \x01(\x0b\x32 .ray.rpc.PlacementGroupTableDataR\x17placementGroupTableData\"(\n\rDrainNodeData\x12\x17\n\x07node_id\x18\x01 \x01(\x0cR\x06nodeId\"R\n\x10\x44rainNodeRequest\x12>\n\x0f\x64rain_node_data\x18\x01 \x03(\x0b\x32\x16.ray.rpc.DrainNodeDataR\rdrainNodeData\"*\n\x0f\x44rainNodeStatus\x12\x17\n\x07node_id\x18\x01 \x01(\x0cR\x06nodeId\"\x82\x01\n\x0e\x44rainNodeReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12\x44\n\x11\x64rain_node_status\x18\x02 \x03(\x0b\x32\x18.ray.rpc.DrainNodeStatusR\x0f\x64rainNodeStatus\"F\n\x14InternalKVGetRequest\x12\x10\n\x03key\x18\x01 \x01(\x0cR\x03key\x12\x1c\n\tnamespace\x18\x02 \x01(\x0cR\tnamespace\"V\n\x12InternalKVGetReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12\x14\n\x05value\x18\x02 \x01(\x0cR\x05value\"M\n\x19InternalKVMultiGetRequest\x12\x12\n\x04keys\x18\x01 \x03(\x0cR\x04keys\x12\x1c\n\tnamespace\x18\x02 \x01(\x0cR\tnamespace\"7\n\rMapFieldEntry\x12\x10\n\x03key\x18\x01 \x01(\x0cR\x03key\x12\x14\n\x05value\x18\x02 \x01(\x0cR\x05value\"w\n\x17InternalKVMultiGetReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12\x30\n\x07results\x18\x02 \x03(\x0b\x32\x16.ray.rpc.MapFieldEntryR\x07results\"z\n\x14InternalKVPutRequest\x12\x10\n\x03key\x18\x01 \x01(\x0cR\x03key\x12\x14\n\x05value\x18\x02 \x01(\x0cR\x05value\x12\x1c\n\toverwrite\x18\x03 \x01(\x08R\toverwrite\x12\x1c\n\tnamespace\x18\x04 \x01(\x0cR\tnamespace\"V\n\x12InternalKVPutReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12\x14\n\x05\x61\x64\x64\x65\x64\x18\x02 \x01(\x08R\x05\x61\x64\x64\x65\x64\"j\n\x14InternalKVDelRequest\x12\x10\n\x03key\x18\x01 \x01(\x0cR\x03key\x12\x1c\n\tnamespace\x18\x02 \x01(\x0cR\tnamespace\x12\"\n\rdel_by_prefix\x18\x03 \x01(\x08R\x0b\x64\x65lByPrefix\"a\n\x12InternalKVDelReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12\x1f\n\x0b\x64\x65leted_num\x18\x02 \x01(\x05R\ndeletedNum\"I\n\x17InternalKVExistsRequest\x12\x10\n\x03key\x18\x01 \x01(\x0cR\x03key\x12\x1c\n\tnamespace\x18\x02 \x01(\x0cR\tnamespace\"[\n\x15InternalKVExistsReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12\x16\n\x06\x65xists\x18\x02 \x01(\x08R\x06\x65xists\"M\n\x15InternalKVKeysRequest\x12\x16\n\x06prefix\x18\x01 \x01(\x0cR\x06prefix\x12\x1c\n\tnamespace\x18\x02 \x01(\x0cR\tnamespace\"[\n\x13InternalKVKeysReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12\x18\n\x07results\x18\x02 \x03(\x0cR\x07results\"N\n\x17PinRuntimeEnvURIRequest\x12\x10\n\x03uri\x18\x01 \x01(\tR\x03uri\x12!\n\x0c\x65xpiration_s\x18\x02 \x01(\x05R\x0b\x65xpirationS\"C\n\x15PinRuntimeEnvURIReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\"K\n\x11GcsPublishRequest\x12\x36\n\x0cpub_messages\x18\x01 \x03(\x0b\x32\x13.ray.rpc.PubMessageR\x0bpubMessages\"=\n\x0fGcsPublishReply\x12*\n\x06status\x18\x64 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\"\x9d\x01\n\x18GcsSubscriberPollRequest\x12#\n\rsubscriber_id\x18\x01 \x01(\x0cR\x0csubscriberId\x12\x39\n\x19max_processed_sequence_id\x18\x02 \x01(\x03R\x16maxProcessedSequenceId\x12!\n\x0cpublisher_id\x18\x03 \x01(\x0cR\x0bpublisherId\"\x9f\x01\n\x16GcsSubscriberPollReply\x12\x36\n\x0cpub_messages\x18\x01 \x03(\x0b\x32\x13.ray.rpc.PubMessageR\x0bpubMessages\x12!\n\x0cpublisher_id\x18\x02 \x01(\x0cR\x0bpublisherId\x12*\n\x06status\x18\x64 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\"\x92\x01\n GcsSubscriberCommandBatchRequest\x12#\n\rsubscriber_id\x18\x01 \x01(\x0cR\x0csubscriberId\x12,\n\x08\x63ommands\x18\x02 \x03(\x0b\x32\x10.ray.rpc.CommandR\x08\x63ommands\x12\x1b\n\tsender_id\x18\x03 \x01(\x0cR\x08senderId\"L\n\x1eGcsSubscriberCommandBatchReply\x12*\n\x06status\x18\x64 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\"\x1c\n\x1aGetAllResourceUsageRequest\"\x97\x01\n\x18GetAllResourceUsageReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12O\n\x13resource_usage_data\x18\x02 \x01(\x0b\x32\x1f.ray.rpc.ResourceUsageBatchDataR\x11resourceUsageData\"\x19\n\x17GetDrainingNodesRequest\"l\n\x0c\x44rainingNode\x12\x17\n\x07node_id\x18\x01 \x01(\x0cR\x06nodeId\x12\x43\n\x1e\x64raining_deadline_timestamp_ms\x18\x02 \x01(\x03R\x1b\x64rainingDeadlineTimestampMs\"\x81\x01\n\x15GetDrainingNodesReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12<\n\x0e\x64raining_nodes\x18\x02 \x03(\x0b\x32\x15.ray.rpc.DrainingNodeR\rdrainingNodes\"9\n\tGcsStatus\x12\x12\n\x04\x63ode\x18\x01 \x01(\x05R\x04\x63ode\x12\x18\n\x07message\x18\x02 \x01(\tR\x07message\"E\n\x17\x41\x64\x64TaskEventDataRequest\x12*\n\x04\x64\x61ta\x18\x01 \x01(\x0b\x32\x16.ray.rpc.TaskEventDataR\x04\x64\x61ta\"C\n\x15\x41\x64\x64TaskEventDataReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\"\xfe\x08\n\x14GetTaskEventsRequest\x12\x19\n\x05limit\x18\x03 \x01(\x03H\x00R\x05limit\x88\x01\x01\x12\x44\n\x07\x66ilters\x18\x04 \x01(\x0b\x32%.ray.rpc.GetTaskEventsRequest.FiltersH\x01R\x07\x66ilters\x88\x01\x01\x1a\xee\x07\n\x07\x46ilters\x12R\n\x0bjob_filters\x18\x01 \x03(\x0b\x32\x31.ray.rpc.GetTaskEventsRequest.Filters.JobIdFilterR\njobFilters\x12U\n\x0ctask_filters\x18\x02 \x03(\x0b\x32\x32.ray.rpc.GetTaskEventsRequest.Filters.TaskIdFilterR\x0btaskFilters\x12X\n\ractor_filters\x18\x03 \x03(\x0b\x32\x33.ray.rpc.GetTaskEventsRequest.Filters.ActorIdFilterR\x0c\x61\x63torFilters\x12`\n\x11task_name_filters\x18\x04 \x03(\x0b\x32\x34.ray.rpc.GetTaskEventsRequest.Filters.TaskNameFilterR\x0ftaskNameFilters\x12*\n\x0e\x65xclude_driver\x18\x05 \x01(\x08H\x00R\rexcludeDriver\x88\x01\x01\x12V\n\rstate_filters\x18\x06 \x03(\x0b\x32\x31.ray.rpc.GetTaskEventsRequest.Filters.StateFilterR\x0cstateFilters\x1a\\\n\x0bJobIdFilter\x12\x36\n\tpredicate\x18\x01 \x01(\x0e\x32\x18.ray.rpc.FilterPredicateR\tpredicate\x12\x15\n\x06job_id\x18\x02 \x01(\x0cR\x05jobId\x1a_\n\x0cTaskIdFilter\x12\x36\n\tpredicate\x18\x01 \x01(\x0e\x32\x18.ray.rpc.FilterPredicateR\tpredicate\x12\x17\n\x07task_id\x18\x02 \x01(\x0cR\x06taskId\x1a\x62\n\rActorIdFilter\x12\x36\n\tpredicate\x18\x01 \x01(\x0e\x32\x18.ray.rpc.FilterPredicateR\tpredicate\x12\x19\n\x08\x61\x63tor_id\x18\x02 \x01(\x0cR\x07\x61\x63torId\x1a\x65\n\x0eTaskNameFilter\x12\x36\n\tpredicate\x18\x01 \x01(\x0e\x32\x18.ray.rpc.FilterPredicateR\tpredicate\x12\x1b\n\ttask_name\x18\x02 \x01(\tR\x08taskName\x1a[\n\x0bStateFilter\x12\x36\n\tpredicate\x18\x01 \x01(\x0e\x32\x18.ray.rpc.FilterPredicateR\tpredicate\x12\x14\n\x05state\x18\x02 \x01(\tR\x05stateB\x11\n\x0f_exclude_driverB\x08\n\x06_limitB\n\n\x08_filters\"\x83\x03\n\x12GetTaskEventsReply\x12*\n\x06status\x18\x01 \x01(\x0b\x32\x12.ray.rpc.GcsStatusR\x06status\x12\x39\n\x0e\x65vents_by_task\x18\x02 \x03(\x0b\x32\x13.ray.rpc.TaskEventsR\x0c\x65ventsByTask\x12\x44\n\x1fnum_profile_task_events_dropped\x18\x03 \x01(\x05R\x1bnumProfileTaskEventsDropped\x12\x42\n\x1enum_status_task_events_dropped\x18\x04 \x01(\x05R\x1anumStatusTaskEventsDropped\x12(\n\x10num_total_stored\x18\x05 \x01(\x03R\x0enumTotalStored\x12-\n\x13num_filtered_on_gcs\x18\x06 \x01(\x03R\x10numFilteredOnGcs\x12#\n\rnum_truncated\x18\x07 \x01(\x03R\x0cnumTruncated*C\n\x15GcsServiceFailureType\x12\x12\n\x0eRPC_DISCONNECT\x10\x00\x12\x16\n\x12GCS_SERVER_RESTART\x10\x01*+\n\x0f\x46ilterPredicate\x12\t\n\x05\x45QUAL\x10\x00\x12\r\n\tNOT_EQUAL\x10\x01\x32\x85\x03\n\x11JobInfoGcsService\x12\x36\n\x06\x41\x64\x64Job\x12\x16.ray.rpc.AddJobRequest\x1a\x14.ray.rpc.AddJobReply\x12Q\n\x0fMarkJobFinished\x12\x1f.ray.rpc.MarkJobFinishedRequest\x1a\x1d.ray.rpc.MarkJobFinishedReply\x12K\n\rGetAllJobInfo\x12\x1d.ray.rpc.GetAllJobInfoRequest\x1a\x1b.ray.rpc.GetAllJobInfoReply\x12N\n\x0eReportJobError\x12\x1e.ray.rpc.ReportJobErrorRequest\x1a\x1c.ray.rpc.ReportJobErrorReply\x12H\n\x0cGetNextJobID\x12\x1c.ray.rpc.GetNextJobIDRequest\x1a\x1a.ray.rpc.GetNextJobIDReply2\xbd\x06\n\x13\x41\x63torInfoGcsService\x12K\n\rRegisterActor\x12\x1d.ray.rpc.RegisterActorRequest\x1a\x1b.ray.rpc.RegisterActorReply\x12\x90\x01\n$RestartActorForLineageReconstruction\x12\x34.ray.rpc.RestartActorForLineageReconstructionRequest\x1a\x32.ray.rpc.RestartActorForLineageReconstructionReply\x12\x45\n\x0b\x43reateActor\x12\x1b.ray.rpc.CreateActorRequest\x1a\x19.ray.rpc.CreateActorReply\x12H\n\x0cGetActorInfo\x12\x1c.ray.rpc.GetActorInfoRequest\x1a\x1a.ray.rpc.GetActorInfoReply\x12W\n\x11GetNamedActorInfo\x12!.ray.rpc.GetNamedActorInfoRequest\x1a\x1f.ray.rpc.GetNamedActorInfoReply\x12Q\n\x0fListNamedActors\x12\x1f.ray.rpc.ListNamedActorsRequest\x1a\x1d.ray.rpc.ListNamedActorsReply\x12Q\n\x0fGetAllActorInfo\x12\x1f.ray.rpc.GetAllActorInfoRequest\x1a\x1d.ray.rpc.GetAllActorInfoReply\x12Q\n\x0fKillActorViaGcs\x12\x1f.ray.rpc.KillActorViaGcsRequest\x1a\x1d.ray.rpc.KillActorViaGcsReply\x12\x63\n\x15ReportActorOutOfScope\x12%.ray.rpc.ReportActorOutOfScopeRequest\x1a#.ray.rpc.ReportActorOutOfScopeReply2\xcd\x04\n\x14WorkerInfoGcsService\x12]\n\x13ReportWorkerFailure\x12#.ray.rpc.ReportWorkerFailureRequest\x1a!.ray.rpc.ReportWorkerFailureReply\x12K\n\rGetWorkerInfo\x12\x1d.ray.rpc.GetWorkerInfoRequest\x1a\x1b.ray.rpc.GetWorkerInfoReply\x12T\n\x10GetAllWorkerInfo\x12 .ray.rpc.GetAllWorkerInfoRequest\x1a\x1e.ray.rpc.GetAllWorkerInfoReply\x12K\n\rAddWorkerInfo\x12\x1d.ray.rpc.AddWorkerInfoRequest\x1a\x1b.ray.rpc.AddWorkerInfoReply\x12l\n\x18UpdateWorkerDebuggerPort\x12(.ray.rpc.UpdateWorkerDebuggerPortRequest\x1a&.ray.rpc.UpdateWorkerDebuggerPortReply\x12x\n\x1cUpdateWorkerNumPausedThreads\x12,.ray.rpc.UpdateWorkerNumPausedThreadsRequest\x1a*.ray.rpc.UpdateWorkerNumPausedThreadsReply2\xff\x04\n\x1cPlacementGroupInfoGcsService\x12`\n\x14\x43reatePlacementGroup\x12$.ray.rpc.CreatePlacementGroupRequest\x1a\".ray.rpc.CreatePlacementGroupReply\x12`\n\x14RemovePlacementGroup\x12$.ray.rpc.RemovePlacementGroupRequest\x1a\".ray.rpc.RemovePlacementGroupReply\x12W\n\x11GetPlacementGroup\x12!.ray.rpc.GetPlacementGroupRequest\x1a\x1f.ray.rpc.GetPlacementGroupReply\x12\x66\n\x16GetNamedPlacementGroup\x12&.ray.rpc.GetNamedPlacementGroupRequest\x1a$.ray.rpc.GetNamedPlacementGroupReply\x12`\n\x14GetAllPlacementGroup\x12$.ray.rpc.GetAllPlacementGroupRequest\x1a\".ray.rpc.GetAllPlacementGroupReply\x12x\n\x1cWaitPlacementGroupUntilReady\x12,.ray.rpc.WaitPlacementGroupUntilReadyRequest\x1a*.ray.rpc.WaitPlacementGroupUntilReadyReply2\xd8\x04\n\x14InternalKVGcsService\x12K\n\rInternalKVGet\x12\x1d.ray.rpc.InternalKVGetRequest\x1a\x1b.ray.rpc.InternalKVGetReply\x12Z\n\x12InternalKVMultiGet\x12\".ray.rpc.InternalKVMultiGetRequest\x1a .ray.rpc.InternalKVMultiGetReply\x12K\n\rInternalKVPut\x12\x1d.ray.rpc.InternalKVPutRequest\x1a\x1b.ray.rpc.InternalKVPutReply\x12K\n\rInternalKVDel\x12\x1d.ray.rpc.InternalKVDelRequest\x1a\x1b.ray.rpc.InternalKVDelReply\x12T\n\x10InternalKVExists\x12 .ray.rpc.InternalKVExistsRequest\x1a\x1e.ray.rpc.InternalKVExistsReply\x12N\n\x0eInternalKVKeys\x12\x1e.ray.rpc.InternalKVKeysRequest\x1a\x1c.ray.rpc.InternalKVKeysReply\x12W\n\x11GetInternalConfig\x12!.ray.rpc.GetInternalConfigRequest\x1a\x1f.ray.rpc.GetInternalConfigReply2l\n\x14RuntimeEnvGcsService\x12T\n\x10PinRuntimeEnvURI\x12 .ray.rpc.PinRuntimeEnvURIRequest\x1a\x1e.ray.rpc.PinRuntimeEnvURIReply2\xa8\x02\n\x18InternalPubSubGcsService\x12\x42\n\nGcsPublish\x12\x1a.ray.rpc.GcsPublishRequest\x1a\x18.ray.rpc.GcsPublishReply\x12W\n\x11GcsSubscriberPoll\x12!.ray.rpc.GcsSubscriberPollRequest\x1a\x1f.ray.rpc.GcsSubscriberPollReply\x12o\n\x19GcsSubscriberCommandBatch\x12).ray.rpc.GcsSubscriberCommandBatchRequest\x1a\'.ray.rpc.GcsSubscriberCommandBatchReply2\xa1\x03\n\x1aNodeResourceInfoGcsService\x12l\n\x18GetAllAvailableResources\x12(.ray.rpc.GetAllAvailableResourcesRequest\x1a&.ray.rpc.GetAllAvailableResourcesReply\x12`\n\x14GetAllTotalResources\x12$.ray.rpc.GetAllTotalResourcesRequest\x1a\".ray.rpc.GetAllTotalResourcesReply\x12]\n\x13GetAllResourceUsage\x12#.ray.rpc.GetAllResourceUsageRequest\x1a!.ray.rpc.GetAllResourceUsageReply\x12T\n\x10GetDrainingNodes\x12 .ray.rpc.GetDrainingNodesRequest\x1a\x1e.ray.rpc.GetDrainingNodesReply2\xc7\x04\n\x12NodeInfoGcsService\x12H\n\x0cGetClusterId\x12\x1c.ray.rpc.GetClusterIdRequest\x1a\x1a.ray.rpc.GetClusterIdReply\x12H\n\x0cRegisterNode\x12\x1c.ray.rpc.RegisterNodeRequest\x1a\x1a.ray.rpc.RegisterNodeReply\x12N\n\x0eUnregisterNode\x12\x1e.ray.rpc.UnregisterNodeRequest\x1a\x1c.ray.rpc.UnregisterNodeReply\x12?\n\tDrainNode\x12\x19.ray.rpc.DrainNodeRequest\x1a\x17.ray.rpc.DrainNodeReply\x12N\n\x0eGetAllNodeInfo\x12\x1e.ray.rpc.GetAllNodeInfoRequest\x1a\x1c.ray.rpc.GetAllNodeInfoReply\x12x\n\x1cGetAllNodeAddressAndLiveness\x12,.ray.rpc.GetAllNodeAddressAndLivenessRequest\x1a*.ray.rpc.GetAllNodeAddressAndLivenessReply\x12\x42\n\nCheckAlive\x12\x1a.ray.rpc.CheckAliveRequest\x1a\x18.ray.rpc.CheckAliveReply2\xb7\x01\n\x12TaskInfoGcsService\x12T\n\x10\x41\x64\x64TaskEventData\x12 .ray.rpc.AddTaskEventDataRequest\x1a\x1e.ray.rpc.AddTaskEventDataReply\x12K\n\rGetTaskEvents\x12\x1d.ray.rpc.GetTaskEventsRequest\x1a\x1b.ray.rpc.GetTaskEventsReply2i\n\x18RayEventExportGcsService\x12M\n\tAddEvents\x12 .ray.rpc.events.AddEventsRequest\x1a\x1e.ray.rpc.events.AddEventsReplyb\x06proto3')

_GCSSERVICEFAILURETYPE = DESCRIPTOR.enum_types_by_name['GcsServiceFailureType']
GcsServiceFailureType = enum_type_wrapper.EnumTypeWrapper(_GCSSERVICEFAILURETYPE)
_FILTERPREDICATE = DESCRIPTOR.enum_types_by_name['FilterPredicate']
FilterPredicate = enum_type_wrapper.EnumTypeWrapper(_FILTERPREDICATE)
RPC_DISCONNECT = 0
GCS_SERVER_RESTART = 1
EQUAL = 0
NOT_EQUAL = 1


_ADDJOBREQUEST = DESCRIPTOR.message_types_by_name['AddJobRequest']
_ADDJOBREPLY = DESCRIPTOR.message_types_by_name['AddJobReply']
_MARKJOBFINISHEDREQUEST = DESCRIPTOR.message_types_by_name['MarkJobFinishedRequest']
_MARKJOBFINISHEDREPLY = DESCRIPTOR.message_types_by_name['MarkJobFinishedReply']
_GETALLJOBINFOREQUEST = DESCRIPTOR.message_types_by_name['GetAllJobInfoRequest']
_GETALLJOBINFOREPLY = DESCRIPTOR.message_types_by_name['GetAllJobInfoReply']
_REPORTJOBERRORREQUEST = DESCRIPTOR.message_types_by_name['ReportJobErrorRequest']
_REPORTJOBERRORREPLY = DESCRIPTOR.message_types_by_name['ReportJobErrorReply']
_GETNEXTJOBIDREQUEST = DESCRIPTOR.message_types_by_name['GetNextJobIDRequest']
_GETNEXTJOBIDREPLY = DESCRIPTOR.message_types_by_name['GetNextJobIDReply']
_GETACTORINFOREQUEST = DESCRIPTOR.message_types_by_name['GetActorInfoRequest']
_GETACTORINFOREPLY = DESCRIPTOR.message_types_by_name['GetActorInfoReply']
_GETNAMEDACTORINFOREQUEST = DESCRIPTOR.message_types_by_name['GetNamedActorInfoRequest']
_GETNAMEDACTORINFOREPLY = DESCRIPTOR.message_types_by_name['GetNamedActorInfoReply']
_LISTNAMEDACTORSREQUEST = DESCRIPTOR.message_types_by_name['ListNamedActorsRequest']
_LISTNAMEDACTORSREPLY = DESCRIPTOR.message_types_by_name['ListNamedActorsReply']
_GETALLACTORINFOREQUEST = DESCRIPTOR.message_types_by_name['GetAllActorInfoRequest']
_GETALLACTORINFOREQUEST_FILTERS = _GETALLACTORINFOREQUEST.nested_types_by_name['Filters']
_GETALLACTORINFOREPLY = DESCRIPTOR.message_types_by_name['GetAllActorInfoReply']
_KILLACTORVIAGCSREQUEST = DESCRIPTOR.message_types_by_name['KillActorViaGcsRequest']
_KILLACTORVIAGCSREPLY = DESCRIPTOR.message_types_by_name['KillActorViaGcsReply']
_REPORTACTOROUTOFSCOPEREQUEST = DESCRIPTOR.message_types_by_name['ReportActorOutOfScopeRequest']
_REPORTACTOROUTOFSCOPEREPLY = DESCRIPTOR.message_types_by_name['ReportActorOutOfScopeReply']
_GETCLUSTERIDREQUEST = DESCRIPTOR.message_types_by_name['GetClusterIdRequest']
_GETCLUSTERIDREPLY = DESCRIPTOR.message_types_by_name['GetClusterIdReply']
_REGISTERNODEREQUEST = DESCRIPTOR.message_types_by_name['RegisterNodeRequest']
_REGISTERNODEREPLY = DESCRIPTOR.message_types_by_name['RegisterNodeReply']
_UNREGISTERNODEREQUEST = DESCRIPTOR.message_types_by_name['UnregisterNodeRequest']
_UNREGISTERNODEREPLY = DESCRIPTOR.message_types_by_name['UnregisterNodeReply']
_GETALLNODEINFOREQUEST = DESCRIPTOR.message_types_by_name['GetAllNodeInfoRequest']
_GETALLNODEINFOREQUEST_NODESELECTOR = _GETALLNODEINFOREQUEST.nested_types_by_name['NodeSelector']
_GETALLNODEINFOREPLY = DESCRIPTOR.message_types_by_name['GetAllNodeInfoReply']
_GETALLNODEADDRESSANDLIVENESSREQUEST = DESCRIPTOR.message_types_by_name['GetAllNodeAddressAndLivenessRequest']
_GETALLNODEADDRESSANDLIVENESSREPLY = DESCRIPTOR.message_types_by_name['GetAllNodeAddressAndLivenessReply']
_CHECKALIVEREQUEST = DESCRIPTOR.message_types_by_name['CheckAliveRequest']
_CHECKALIVEREPLY = DESCRIPTOR.message_types_by_name['CheckAliveReply']
_GETINTERNALCONFIGREQUEST = DESCRIPTOR.message_types_by_name['GetInternalConfigRequest']
_GETINTERNALCONFIGREPLY = DESCRIPTOR.message_types_by_name['GetInternalConfigReply']
_DELETERESOURCESREPLY = DESCRIPTOR.message_types_by_name['DeleteResourcesReply']
_GETALLAVAILABLERESOURCESREQUEST = DESCRIPTOR.message_types_by_name['GetAllAvailableResourcesRequest']
_GETALLAVAILABLERESOURCESREPLY = DESCRIPTOR.message_types_by_name['GetAllAvailableResourcesReply']
_GETALLTOTALRESOURCESREQUEST = DESCRIPTOR.message_types_by_name['GetAllTotalResourcesRequest']
_GETALLTOTALRESOURCESREPLY = DESCRIPTOR.message_types_by_name['GetAllTotalResourcesReply']
_REPORTWORKERFAILUREREQUEST = DESCRIPTOR.message_types_by_name['ReportWorkerFailureRequest']
_REPORTWORKERFAILUREREPLY = DESCRIPTOR.message_types_by_name['ReportWorkerFailureReply']
_GETWORKERINFOREQUEST = DESCRIPTOR.message_types_by_name['GetWorkerInfoRequest']
_GETWORKERINFOREPLY = DESCRIPTOR.message_types_by_name['GetWorkerInfoReply']
_GETALLWORKERINFOREQUEST = DESCRIPTOR.message_types_by_name['GetAllWorkerInfoRequest']
_GETALLWORKERINFOREQUEST_FILTERS = _GETALLWORKERINFOREQUEST.nested_types_by_name['Filters']
_GETALLWORKERINFOREPLY = DESCRIPTOR.message_types_by_name['GetAllWorkerInfoReply']
_ADDWORKERINFOREQUEST = DESCRIPTOR.message_types_by_name['AddWorkerInfoRequest']
_ADDWORKERINFOREPLY = DESCRIPTOR.message_types_by_name['AddWorkerInfoReply']
_UPDATEWORKERDEBUGGERPORTREQUEST = DESCRIPTOR.message_types_by_name['UpdateWorkerDebuggerPortRequest']
_UPDATEWORKERDEBUGGERPORTREPLY = DESCRIPTOR.message_types_by_name['UpdateWorkerDebuggerPortReply']
_UPDATEWORKERNUMPAUSEDTHREADSREQUEST = DESCRIPTOR.message_types_by_name['UpdateWorkerNumPausedThreadsRequest']
_UPDATEWORKERNUMPAUSEDTHREADSREPLY = DESCRIPTOR.message_types_by_name['UpdateWorkerNumPausedThreadsReply']
_CREATEACTORREQUEST = DESCRIPTOR.message_types_by_name['CreateActorRequest']
_CREATEACTORREPLY = DESCRIPTOR.message_types_by_name['CreateActorReply']
_REGISTERACTORREQUEST = DESCRIPTOR.message_types_by_name['RegisterActorRequest']
_REGISTERACTORREPLY = DESCRIPTOR.message_types_by_name['RegisterActorReply']
_RESTARTACTORFORLINEAGERECONSTRUCTIONREQUEST = DESCRIPTOR.message_types_by_name['RestartActorForLineageReconstructionRequest']
_RESTARTACTORFORLINEAGERECONSTRUCTIONREPLY = DESCRIPTOR.message_types_by_name['RestartActorForLineageReconstructionReply']
_CREATEPLACEMENTGROUPREQUEST = DESCRIPTOR.message_types_by_name['CreatePlacementGroupRequest']
_CREATEPLACEMENTGROUPREPLY = DESCRIPTOR.message_types_by_name['CreatePlacementGroupReply']
_REMOVEPLACEMENTGROUPREQUEST = DESCRIPTOR.message_types_by_name['RemovePlacementGroupRequest']
_REMOVEPLACEMENTGROUPREPLY = DESCRIPTOR.message_types_by_name['RemovePlacementGroupReply']
_GETPLACEMENTGROUPREQUEST = DESCRIPTOR.message_types_by_name['GetPlacementGroupRequest']
_GETPLACEMENTGROUPREPLY = DESCRIPTOR.message_types_by_name['GetPlacementGroupReply']
_GETALLPLACEMENTGROUPREQUEST = DESCRIPTOR.message_types_by_name['GetAllPlacementGroupRequest']
_GETALLPLACEMENTGROUPREPLY = DESCRIPTOR.message_types_by_name['GetAllPlacementGroupReply']
_WAITPLACEMENTGROUPUNTILREADYREQUEST = DESCRIPTOR.message_types_by_name['WaitPlacementGroupUntilReadyRequest']
_WAITPLACEMENTGROUPUNTILREADYREPLY = DESCRIPTOR.message_types_by_name['WaitPlacementGroupUntilReadyReply']
_GETNAMEDPLACEMENTGROUPREQUEST = DESCRIPTOR.message_types_by_name['GetNamedPlacementGroupRequest']
_GETNAMEDPLACEMENTGROUPREPLY = DESCRIPTOR.message_types_by_name['GetNamedPlacementGroupReply']
_DRAINNODEDATA = DESCRIPTOR.message_types_by_name['DrainNodeData']
_DRAINNODEREQUEST = DESCRIPTOR.message_types_by_name['DrainNodeRequest']
_DRAINNODESTATUS = DESCRIPTOR.message_types_by_name['DrainNodeStatus']
_DRAINNODEREPLY = DESCRIPTOR.message_types_by_name['DrainNodeReply']
_INTERNALKVGETREQUEST = DESCRIPTOR.message_types_by_name['InternalKVGetRequest']
_INTERNALKVGETREPLY = DESCRIPTOR.message_types_by_name['InternalKVGetReply']
_INTERNALKVMULTIGETREQUEST = DESCRIPTOR.message_types_by_name['InternalKVMultiGetRequest']
_MAPFIELDENTRY = DESCRIPTOR.message_types_by_name['MapFieldEntry']
_INTERNALKVMULTIGETREPLY = DESCRIPTOR.message_types_by_name['InternalKVMultiGetReply']
_INTERNALKVPUTREQUEST = DESCRIPTOR.message_types_by_name['InternalKVPutRequest']
_INTERNALKVPUTREPLY = DESCRIPTOR.message_types_by_name['InternalKVPutReply']
_INTERNALKVDELREQUEST = DESCRIPTOR.message_types_by_name['InternalKVDelRequest']
_INTERNALKVDELREPLY = DESCRIPTOR.message_types_by_name['InternalKVDelReply']
_INTERNALKVEXISTSREQUEST = DESCRIPTOR.message_types_by_name['InternalKVExistsRequest']
_INTERNALKVEXISTSREPLY = DESCRIPTOR.message_types_by_name['InternalKVExistsReply']
_INTERNALKVKEYSREQUEST = DESCRIPTOR.message_types_by_name['InternalKVKeysRequest']
_INTERNALKVKEYSREPLY = DESCRIPTOR.message_types_by_name['InternalKVKeysReply']
_PINRUNTIMEENVURIREQUEST = DESCRIPTOR.message_types_by_name['PinRuntimeEnvURIRequest']
_PINRUNTIMEENVURIREPLY = DESCRIPTOR.message_types_by_name['PinRuntimeEnvURIReply']
_GCSPUBLISHREQUEST = DESCRIPTOR.message_types_by_name['GcsPublishRequest']
_GCSPUBLISHREPLY = DESCRIPTOR.message_types_by_name['GcsPublishReply']
_GCSSUBSCRIBERPOLLREQUEST = DESCRIPTOR.message_types_by_name['GcsSubscriberPollRequest']
_GCSSUBSCRIBERPOLLREPLY = DESCRIPTOR.message_types_by_name['GcsSubscriberPollReply']
_GCSSUBSCRIBERCOMMANDBATCHREQUEST = DESCRIPTOR.message_types_by_name['GcsSubscriberCommandBatchRequest']
_GCSSUBSCRIBERCOMMANDBATCHREPLY = DESCRIPTOR.message_types_by_name['GcsSubscriberCommandBatchReply']
_GETALLRESOURCEUSAGEREQUEST = DESCRIPTOR.message_types_by_name['GetAllResourceUsageRequest']
_GETALLRESOURCEUSAGEREPLY = DESCRIPTOR.message_types_by_name['GetAllResourceUsageReply']
_GETDRAININGNODESREQUEST = DESCRIPTOR.message_types_by_name['GetDrainingNodesRequest']
_DRAININGNODE = DESCRIPTOR.message_types_by_name['DrainingNode']
_GETDRAININGNODESREPLY = DESCRIPTOR.message_types_by_name['GetDrainingNodesReply']
_GCSSTATUS = DESCRIPTOR.message_types_by_name['GcsStatus']
_ADDTASKEVENTDATAREQUEST = DESCRIPTOR.message_types_by_name['AddTaskEventDataRequest']
_ADDTASKEVENTDATAREPLY = DESCRIPTOR.message_types_by_name['AddTaskEventDataReply']
_GETTASKEVENTSREQUEST = DESCRIPTOR.message_types_by_name['GetTaskEventsRequest']
_GETTASKEVENTSREQUEST_FILTERS = _GETTASKEVENTSREQUEST.nested_types_by_name['Filters']
_GETTASKEVENTSREQUEST_FILTERS_JOBIDFILTER = _GETTASKEVENTSREQUEST_FILTERS.nested_types_by_name['JobIdFilter']
_GETTASKEVENTSREQUEST_FILTERS_TASKIDFILTER = _GETTASKEVENTSREQUEST_FILTERS.nested_types_by_name['TaskIdFilter']
_GETTASKEVENTSREQUEST_FILTERS_ACTORIDFILTER = _GETTASKEVENTSREQUEST_FILTERS.nested_types_by_name['ActorIdFilter']
_GETTASKEVENTSREQUEST_FILTERS_TASKNAMEFILTER = _GETTASKEVENTSREQUEST_FILTERS.nested_types_by_name['TaskNameFilter']
_GETTASKEVENTSREQUEST_FILTERS_STATEFILTER = _GETTASKEVENTSREQUEST_FILTERS.nested_types_by_name['StateFilter']
_GETTASKEVENTSREPLY = DESCRIPTOR.message_types_by_name['GetTaskEventsReply']
AddJobRequest = _reflection.GeneratedProtocolMessageType('AddJobRequest', (_message.Message,), {
  'DESCRIPTOR' : _ADDJOBREQUEST,
  '__module__' : 'src.ray.protobuf.gcs_service_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.AddJobRequest)
  })
_sym_db.RegisterMessage(AddJobRequest)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

  'Filters' : _reflection.GeneratedProtocolMessageType('Filters', (_message.Message,), {
    'DESCRIPTOR' : _GETALLACTORINFOREQUEST_FILTERS,
    '__module__' : 'src.ray.protobuf.gcs_service_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.GetAllActorInfoRequest.Filters)
    })
  ,
  'DESCRIPTOR' : _GETALLACTORINFOREQUEST,
  '__module__' : 'src.ray.protobuf.gcs_service_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.GetAllActorInfoRequest)
  })
_sym_db.RegisterMessage(GetAllActorInfoRequest)
_sym_db.RegisterMessage(GetAllActorInfoRequest.Filters)

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

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

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

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

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

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

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

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

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

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

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

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

  'NodeSelector' : _reflection.GeneratedProtocolMessageType('NodeSelector', (_message.Message,), {
    'DESCRIPTOR' : _GETALLNODEINFOREQUEST_NODESELECTOR,
    '__module__' : 'src.ray.protobuf.gcs_service_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.GetAllNodeInfoRequest.NodeSelector)
    })
  ,
  'DESCRIPTOR' : _GETALLNODEINFOREQUEST,
  '__module__' : 'src.ray.protobuf.gcs_service_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.GetAllNodeInfoRequest)
  })
_sym_db.RegisterMessage(GetAllNodeInfoRequest)
_sym_db.RegisterMessage(GetAllNodeInfoRequest.NodeSelector)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

  'Filters' : _reflection.GeneratedProtocolMessageType('Filters', (_message.Message,), {
    'DESCRIPTOR' : _GETALLWORKERINFOREQUEST_FILTERS,
    '__module__' : 'src.ray.protobuf.gcs_service_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.GetAllWorkerInfoRequest.Filters)
    })
  ,
  'DESCRIPTOR' : _GETALLWORKERINFOREQUEST,
  '__module__' : 'src.ray.protobuf.gcs_service_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.GetAllWorkerInfoRequest)
  })
_sym_db.RegisterMessage(GetAllWorkerInfoRequest)
_sym_db.RegisterMessage(GetAllWorkerInfoRequest.Filters)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

    'JobIdFilter' : _reflection.GeneratedProtocolMessageType('JobIdFilter', (_message.Message,), {
      'DESCRIPTOR' : _GETTASKEVENTSREQUEST_FILTERS_JOBIDFILTER,
      '__module__' : 'src.ray.protobuf.gcs_service_pb2'
      # @@protoc_insertion_point(class_scope:ray.rpc.GetTaskEventsRequest.Filters.JobIdFilter)
      })
    ,

    'TaskIdFilter' : _reflection.GeneratedProtocolMessageType('TaskIdFilter', (_message.Message,), {
      'DESCRIPTOR' : _GETTASKEVENTSREQUEST_FILTERS_TASKIDFILTER,
      '__module__' : 'src.ray.protobuf.gcs_service_pb2'
      # @@protoc_insertion_point(class_scope:ray.rpc.GetTaskEventsRequest.Filters.TaskIdFilter)
      })
    ,

    'ActorIdFilter' : _reflection.GeneratedProtocolMessageType('ActorIdFilter', (_message.Message,), {
      'DESCRIPTOR' : _GETTASKEVENTSREQUEST_FILTERS_ACTORIDFILTER,
      '__module__' : 'src.ray.protobuf.gcs_service_pb2'
      # @@protoc_insertion_point(class_scope:ray.rpc.GetTaskEventsRequest.Filters.ActorIdFilter)
      })
    ,

    'TaskNameFilter' : _reflection.GeneratedProtocolMessageType('TaskNameFilter', (_message.Message,), {
      'DESCRIPTOR' : _GETTASKEVENTSREQUEST_FILTERS_TASKNAMEFILTER,
      '__module__' : 'src.ray.protobuf.gcs_service_pb2'
      # @@protoc_insertion_point(class_scope:ray.rpc.GetTaskEventsRequest.Filters.TaskNameFilter)
      })
    ,

    'StateFilter' : _reflection.GeneratedProtocolMessageType('StateFilter', (_message.Message,), {
      'DESCRIPTOR' : _GETTASKEVENTSREQUEST_FILTERS_STATEFILTER,
      '__module__' : 'src.ray.protobuf.gcs_service_pb2'
      # @@protoc_insertion_point(class_scope:ray.rpc.GetTaskEventsRequest.Filters.StateFilter)
      })
    ,
    'DESCRIPTOR' : _GETTASKEVENTSREQUEST_FILTERS,
    '__module__' : 'src.ray.protobuf.gcs_service_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.GetTaskEventsRequest.Filters)
    })
  ,
  'DESCRIPTOR' : _GETTASKEVENTSREQUEST,
  '__module__' : 'src.ray.protobuf.gcs_service_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.GetTaskEventsRequest)
  })
_sym_db.RegisterMessage(GetTaskEventsRequest)
_sym_db.RegisterMessage(GetTaskEventsRequest.Filters)
_sym_db.RegisterMessage(GetTaskEventsRequest.Filters.JobIdFilter)
_sym_db.RegisterMessage(GetTaskEventsRequest.Filters.TaskIdFilter)
_sym_db.RegisterMessage(GetTaskEventsRequest.Filters.ActorIdFilter)
_sym_db.RegisterMessage(GetTaskEventsRequest.Filters.TaskNameFilter)
_sym_db.RegisterMessage(GetTaskEventsRequest.Filters.StateFilter)

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

_JOBINFOGCSSERVICE = DESCRIPTOR.services_by_name['JobInfoGcsService']
_ACTORINFOGCSSERVICE = DESCRIPTOR.services_by_name['ActorInfoGcsService']
_WORKERINFOGCSSERVICE = DESCRIPTOR.services_by_name['WorkerInfoGcsService']
_PLACEMENTGROUPINFOGCSSERVICE = DESCRIPTOR.services_by_name['PlacementGroupInfoGcsService']
_INTERNALKVGCSSERVICE = DESCRIPTOR.services_by_name['InternalKVGcsService']
_RUNTIMEENVGCSSERVICE = DESCRIPTOR.services_by_name['RuntimeEnvGcsService']
_INTERNALPUBSUBGCSSERVICE = DESCRIPTOR.services_by_name['InternalPubSubGcsService']
_NODERESOURCEINFOGCSSERVICE = DESCRIPTOR.services_by_name['NodeResourceInfoGcsService']
_NODEINFOGCSSERVICE = DESCRIPTOR.services_by_name['NodeInfoGcsService']
_TASKINFOGCSSERVICE = DESCRIPTOR.services_by_name['TaskInfoGcsService']
_RAYEVENTEXPORTGCSSERVICE = DESCRIPTOR.services_by_name['RayEventExportGcsService']
if _descriptor._USE_C_DESCRIPTORS == False:

  DESCRIPTOR._options = None
  _GCSSERVICEFAILURETYPE._serialized_start=12774
  _GCSSERVICEFAILURETYPE._serialized_end=12841
  _FILTERPREDICATE._serialized_start=12843
  _FILTERPREDICATE._serialized_end=12886
  _ADDJOBREQUEST._serialized_start=193
  _ADDJOBREQUEST._serialized_end=251
  _ADDJOBREPLY._serialized_start=253
  _ADDJOBREPLY._serialized_end=310
  _MARKJOBFINISHEDREQUEST._serialized_start=312
  _MARKJOBFINISHEDREQUEST._serialized_end=359
  _MARKJOBFINISHEDREPLY._serialized_start=361
  _MARKJOBFINISHEDREPLY._serialized_end=427
  _GETALLJOBINFOREQUEST._serialized_start=430
  _GETALLJOBINFOREQUEST._serialized_end=775
  _GETALLJOBINFOREPLY._serialized_start=777
  _GETALLJOBINFOREPLY._serialized_end=900
  _REPORTJOBERRORREQUEST._serialized_start=902
  _REPORTJOBERRORREQUEST._serialized_end=979
  _REPORTJOBERRORREPLY._serialized_start=981
  _REPORTJOBERRORREPLY._serialized_end=1046
  _GETNEXTJOBIDREQUEST._serialized_start=1048
  _GETNEXTJOBIDREQUEST._serialized_end=1069
  _GETNEXTJOBIDREPLY._serialized_start=1071
  _GETNEXTJOBIDREPLY._serialized_end=1157
  _GETACTORINFOREQUEST._serialized_start=1159
  _GETACTORINFOREQUEST._serialized_end=1227
  _GETACTORINFOREPLY._serialized_start=1230
  _GETACTORINFOREPLY._serialized_end=1360
  _GETNAMEDACTORINFOREQUEST._serialized_start=1362
  _GETNAMEDACTORINFOREQUEST._serialized_end=1445
  _GETNAMEDACTORINFOREPLY._serialized_start=1448
  _GETNAMEDACTORINFOREPLY._serialized_end=1631
  _LISTNAMEDACTORSREQUEST._serialized_start=1633
  _LISTNAMEDACTORSREQUEST._serialized_end=1733
  _LISTNAMEDACTORSREPLY._serialized_start=1736
  _LISTNAMEDACTORSREPLY._serialized_end=1871
  _GETALLACTORINFOREQUEST._serialized_start=1874
  _GETALLACTORINFOREQUEST._serialized_end=2226
  _GETALLACTORINFOREQUEST_FILTERS._serialized_start=2038
  _GETALLACTORINFOREQUEST_FILTERS._serialized_end=2204
  _GETALLACTORINFOREPLY._serialized_start=2229
  _GETALLACTORINFOREPLY._serialized_end=2419
  _KILLACTORVIAGCSREQUEST._serialized_start=2421
  _KILLACTORVIAGCSREQUEST._serialized_end=2534
  _KILLACTORVIAGCSREPLY._serialized_start=2536
  _KILLACTORVIAGCSREPLY._serialized_end=2602
  _REPORTACTOROUTOFSCOPEREQUEST._serialized_start=2605
  _REPORTACTOROUTOFSCOPEREQUEST._serialized_end=2753
  _REPORTACTOROUTOFSCOPEREPLY._serialized_start=2755
  _REPORTACTOROUTOFSCOPEREPLY._serialized_end=2827
  _GETCLUSTERIDREQUEST._serialized_start=2829
  _GETCLUSTERIDREQUEST._serialized_end=2850
  _GETCLUSTERIDREPLY._serialized_start=2852
  _GETCLUSTERIDREPLY._serialized_end=2946
  _REGISTERNODEREQUEST._serialized_start=2948
  _REGISTERNODEREQUEST._serialized_end=3020
  _REGISTERNODEREPLY._serialized_start=3022
  _REGISTERNODEREPLY._serialized_end=3085
  _UNREGISTERNODEREQUEST._serialized_start=3087
  _UNREGISTERNODEREQUEST._serialized_end=3199
  _UNREGISTERNODEREPLY._serialized_start=3201
  _UNREGISTERNODEREPLY._serialized_end=3266
  _GETALLNODEINFOREQUEST._serialized_start=3269
  _GETALLNODEINFOREQUEST._serialized_end=3639
  _GETALLNODEINFOREQUEST_NODESELECTOR._serialized_start=3481
  _GETALLNODEINFOREQUEST_NODESELECTOR._serialized_end=3612
  _GETALLNODEINFOREPLY._serialized_start=3642
  _GETALLNODEINFOREPLY._serialized_end=3824
  _GETALLNODEADDRESSANDLIVENESSREQUEST._serialized_start=3827
  _GETALLNODEADDRESSANDLIVENESSREQUEST._serialized_end=4020
  _GETALLNODEADDRESSANDLIVENESSREPLY._serialized_start=4023
  _GETALLNODEADDRESSANDLIVENESSREPLY._serialized_end=4176
  _CHECKALIVEREQUEST._serialized_start=4178
  _CHECKALIVEREQUEST._serialized_end=4224
  _CHECKALIVEREPLY._serialized_start=4227
  _CHECKALIVEREPLY._serialized_end=4356
  _GETINTERNALCONFIGREQUEST._serialized_start=4358
  _GETINTERNALCONFIGREQUEST._serialized_end=4384
  _GETINTERNALCONFIGREPLY._serialized_start=4386
  _GETINTERNALCONFIGREPLY._serialized_end=4478
  _DELETERESOURCESREPLY._serialized_start=4480
  _DELETERESOURCESREPLY._serialized_end=4546
  _GETALLAVAILABLERESOURCESREQUEST._serialized_start=4548
  _GETALLAVAILABLERESOURCESREQUEST._serialized_end=4581
  _GETALLAVAILABLERESOURCESREPLY._serialized_start=4584
  _GETALLAVAILABLERESOURCESREPLY._serialized_end=4727
  _GETALLTOTALRESOURCESREQUEST._serialized_start=4729
  _GETALLTOTALRESOURCESREQUEST._serialized_end=4758
  _GETALLTOTALRESOURCESREPLY._serialized_start=4761
  _GETALLTOTALRESOURCESREPLY._serialized_end=4896
  _REPORTWORKERFAILUREREQUEST._serialized_start=4898
  _REPORTWORKERFAILUREREQUEST._serialized_end=4991
  _REPORTWORKERFAILUREREPLY._serialized_start=4993
  _REPORTWORKERFAILUREREPLY._serialized_end=5063
  _GETWORKERINFOREQUEST._serialized_start=5065
  _GETWORKERINFOREQUEST._serialized_end=5116
  _GETWORKERINFOREPLY._serialized_start=5119
  _GETWORKERINFOREPLY._serialized_end=5253
  _GETALLWORKERINFOREQUEST._serialized_start=5256
  _GETALLWORKERINFOREQUEST._serialized_end=5540
  _GETALLWORKERINFOREQUEST_FILTERS._serialized_start=5384
  _GETALLWORKERINFOREQUEST_FILTERS._serialized_end=5518
  _GETALLWORKERINFOREPLY._serialized_start=5543
  _GETALLWORKERINFOREPLY._serialized_end=5737
  _ADDWORKERINFOREQUEST._serialized_start=5739
  _ADDWORKERINFOREQUEST._serialized_end=5820
  _ADDWORKERINFOREPLY._serialized_start=5822
  _ADDWORKERINFOREPLY._serialized_end=5886
  _UPDATEWORKERDEBUGGERPORTREQUEST._serialized_start=5888
  _UPDATEWORKERDEBUGGERPORTREQUEST._serialized_end=5987
  _UPDATEWORKERDEBUGGERPORTREPLY._serialized_start=5989
  _UPDATEWORKERDEBUGGERPORTREPLY._serialized_end=6064
  _UPDATEWORKERNUMPAUSEDTHREADSREQUEST._serialized_start=6066
  _UPDATEWORKERNUMPAUSEDTHREADSREQUEST._serialized_end=6189
  _UPDATEWORKERNUMPAUSEDTHREADSREPLY._serialized_start=6191
  _UPDATEWORKERNUMPAUSEDTHREADSREPLY._serialized_end=6270
  _CREATEACTORREQUEST._serialized_start=6272
  _CREATEACTORREQUEST._serialized_end=6340
  _CREATEACTORREPLY._serialized_start=6343
  _CREATEACTORREPLY._serialized_end=6608
  _REGISTERACTORREQUEST._serialized_start=6610
  _REGISTERACTORREQUEST._serialized_end=6680
  _REGISTERACTORREPLY._serialized_start=6682
  _REGISTERACTORREPLY._serialized_end=6746
  _RESTARTACTORFORLINEAGERECONSTRUCTIONREQUEST._serialized_start=6749
  _RESTARTACTORFORLINEAGERECONSTRUCTIONREQUEST._serialized_end=6912
  _RESTARTACTORFORLINEAGERECONSTRUCTIONREPLY._serialized_start=6914
  _RESTARTACTORFORLINEAGERECONSTRUCTIONREPLY._serialized_end=7001
  _CREATEPLACEMENTGROUPREQUEST._serialized_start=7003
  _CREATEPLACEMENTGROUPREQUEST._serialized_end=7111
  _CREATEPLACEMENTGROUPREPLY._serialized_start=7113
  _CREATEPLACEMENTGROUPREPLY._serialized_end=7184
  _REMOVEPLACEMENTGROUPREQUEST._serialized_start=7186
  _REMOVEPLACEMENTGROUPREQUEST._serialized_end=7261
  _REMOVEPLACEMENTGROUPREPLY._serialized_start=7263
  _REMOVEPLACEMENTGROUPREPLY._serialized_end=7334
  _GETPLACEMENTGROUPREQUEST._serialized_start=7336
  _GETPLACEMENTGROUPREQUEST._serialized_end=7408
  _GETPLACEMENTGROUPREPLY._serialized_start=7411
  _GETPLACEMENTGROUPREPLY._serialized_end=7574
  _GETALLPLACEMENTGROUPREQUEST._serialized_start=7576
  _GETALLPLACEMENTGROUPREQUEST._serialized_end=7642
  _GETALLPLACEMENTGROUPREPLY._serialized_start=7645
  _GETALLPLACEMENTGROUPREPLY._serialized_end=7833
  _WAITPLACEMENTGROUPUNTILREADYREQUEST._serialized_start=7835
  _WAITPLACEMENTGROUPUNTILREADYREQUEST._serialized_end=7918
  _WAITPLACEMENTGROUPUNTILREADYREPLY._serialized_start=7920
  _WAITPLACEMENTGROUPUNTILREADYREPLY._serialized_end=7999
  _GETNAMEDPLACEMENTGROUPREQUEST._serialized_start=8001
  _GETNAMEDPLACEMENTGROUPREQUEST._serialized_end=8089
  _GETNAMEDPLACEMENTGROUPREPLY._serialized_start=8092
  _GETNAMEDPLACEMENTGROUPREPLY._serialized_end=8260
  _DRAINNODEDATA._serialized_start=8262
  _DRAINNODEDATA._serialized_end=8302
  _DRAINNODEREQUEST._serialized_start=8304
  _DRAINNODEREQUEST._serialized_end=8386
  _DRAINNODESTATUS._serialized_start=8388
  _DRAINNODESTATUS._serialized_end=8430
  _DRAINNODEREPLY._serialized_start=8433
  _DRAINNODEREPLY._serialized_end=8563
  _INTERNALKVGETREQUEST._serialized_start=8565
  _INTERNALKVGETREQUEST._serialized_end=8635
  _INTERNALKVGETREPLY._serialized_start=8637
  _INTERNALKVGETREPLY._serialized_end=8723
  _INTERNALKVMULTIGETREQUEST._serialized_start=8725
  _INTERNALKVMULTIGETREQUEST._serialized_end=8802
  _MAPFIELDENTRY._serialized_start=8804
  _MAPFIELDENTRY._serialized_end=8859
  _INTERNALKVMULTIGETREPLY._serialized_start=8861
  _INTERNALKVMULTIGETREPLY._serialized_end=8980
  _INTERNALKVPUTREQUEST._serialized_start=8982
  _INTERNALKVPUTREQUEST._serialized_end=9104
  _INTERNALKVPUTREPLY._serialized_start=9106
  _INTERNALKVPUTREPLY._serialized_end=9192
  _INTERNALKVDELREQUEST._serialized_start=9194
  _INTERNALKVDELREQUEST._serialized_end=9300
  _INTERNALKVDELREPLY._serialized_start=9302
  _INTERNALKVDELREPLY._serialized_end=9399
  _INTERNALKVEXISTSREQUEST._serialized_start=9401
  _INTERNALKVEXISTSREQUEST._serialized_end=9474
  _INTERNALKVEXISTSREPLY._serialized_start=9476
  _INTERNALKVEXISTSREPLY._serialized_end=9567
  _INTERNALKVKEYSREQUEST._serialized_start=9569
  _INTERNALKVKEYSREQUEST._serialized_end=9646
  _INTERNALKVKEYSREPLY._serialized_start=9648
  _INTERNALKVKEYSREPLY._serialized_end=9739
  _PINRUNTIMEENVURIREQUEST._serialized_start=9741
  _PINRUNTIMEENVURIREQUEST._serialized_end=9819
  _PINRUNTIMEENVURIREPLY._serialized_start=9821
  _PINRUNTIMEENVURIREPLY._serialized_end=9888
  _GCSPUBLISHREQUEST._serialized_start=9890
  _GCSPUBLISHREQUEST._serialized_end=9965
  _GCSPUBLISHREPLY._serialized_start=9967
  _GCSPUBLISHREPLY._serialized_end=10028
  _GCSSUBSCRIBERPOLLREQUEST._serialized_start=10031
  _GCSSUBSCRIBERPOLLREQUEST._serialized_end=10188
  _GCSSUBSCRIBERPOLLREPLY._serialized_start=10191
  _GCSSUBSCRIBERPOLLREPLY._serialized_end=10350
  _GCSSUBSCRIBERCOMMANDBATCHREQUEST._serialized_start=10353
  _GCSSUBSCRIBERCOMMANDBATCHREQUEST._serialized_end=10499
  _GCSSUBSCRIBERCOMMANDBATCHREPLY._serialized_start=10501
  _GCSSUBSCRIBERCOMMANDBATCHREPLY._serialized_end=10577
  _GETALLRESOURCEUSAGEREQUEST._serialized_start=10579
  _GETALLRESOURCEUSAGEREQUEST._serialized_end=10607
  _GETALLRESOURCEUSAGEREPLY._serialized_start=10610
  _GETALLRESOURCEUSAGEREPLY._serialized_end=10761
  _GETDRAININGNODESREQUEST._serialized_start=10763
  _GETDRAININGNODESREQUEST._serialized_end=10788
  _DRAININGNODE._serialized_start=10790
  _DRAININGNODE._serialized_end=10898
  _GETDRAININGNODESREPLY._serialized_start=10901
  _GETDRAININGNODESREPLY._serialized_end=11030
  _GCSSTATUS._serialized_start=11032
  _GCSSTATUS._serialized_end=11089
  _ADDTASKEVENTDATAREQUEST._serialized_start=11091
  _ADDTASKEVENTDATAREQUEST._serialized_end=11160
  _ADDTASKEVENTDATAREPLY._serialized_start=11162
  _ADDTASKEVENTDATAREPLY._serialized_end=11229
  _GETTASKEVENTSREQUEST._serialized_start=11232
  _GETTASKEVENTSREQUEST._serialized_end=12382
  _GETTASKEVENTSREQUEST_FILTERS._serialized_start=11354
  _GETTASKEVENTSREQUEST_FILTERS._serialized_end=12360
  _GETTASKEVENTSREQUEST_FILTERS_JOBIDFILTER._serialized_start=11856
  _GETTASKEVENTSREQUEST_FILTERS_JOBIDFILTER._serialized_end=11948
  _GETTASKEVENTSREQUEST_FILTERS_TASKIDFILTER._serialized_start=11950
  _GETTASKEVENTSREQUEST_FILTERS_TASKIDFILTER._serialized_end=12045
  _GETTASKEVENTSREQUEST_FILTERS_ACTORIDFILTER._serialized_start=12047
  _GETTASKEVENTSREQUEST_FILTERS_ACTORIDFILTER._serialized_end=12145
  _GETTASKEVENTSREQUEST_FILTERS_TASKNAMEFILTER._serialized_start=12147
  _GETTASKEVENTSREQUEST_FILTERS_TASKNAMEFILTER._serialized_end=12248
  _GETTASKEVENTSREQUEST_FILTERS_STATEFILTER._serialized_start=12250
  _GETTASKEVENTSREQUEST_FILTERS_STATEFILTER._serialized_end=12341
  _GETTASKEVENTSREPLY._serialized_start=12385
  _GETTASKEVENTSREPLY._serialized_end=12772
  _JOBINFOGCSSERVICE._serialized_start=12889
  _JOBINFOGCSSERVICE._serialized_end=13278
  _ACTORINFOGCSSERVICE._serialized_start=13281
  _ACTORINFOGCSSERVICE._serialized_end=14110
  _WORKERINFOGCSSERVICE._serialized_start=14113
  _WORKERINFOGCSSERVICE._serialized_end=14702
  _PLACEMENTGROUPINFOGCSSERVICE._serialized_start=14705
  _PLACEMENTGROUPINFOGCSSERVICE._serialized_end=15344
  _INTERNALKVGCSSERVICE._serialized_start=15347
  _INTERNALKVGCSSERVICE._serialized_end=15947
  _RUNTIMEENVGCSSERVICE._serialized_start=15949
  _RUNTIMEENVGCSSERVICE._serialized_end=16057
  _INTERNALPUBSUBGCSSERVICE._serialized_start=16060
  _INTERNALPUBSUBGCSSERVICE._serialized_end=16356
  _NODERESOURCEINFOGCSSERVICE._serialized_start=16359
  _NODERESOURCEINFOGCSSERVICE._serialized_end=16776
  _NODEINFOGCSSERVICE._serialized_start=16779
  _NODEINFOGCSSERVICE._serialized_end=17362
  _TASKINFOGCSSERVICE._serialized_start=17365
  _TASKINFOGCSSERVICE._serialized_end=17548
  _RAYEVENTEXPORTGCSSERVICE._serialized_start=17550
  _RAYEVENTEXPORTGCSSERVICE._serialized_end=17655
# @@protoc_insertion_point(module_scope)