Skip to content

Instantly share code, notes, and snippets.

@simon-mo

simon-mo/common_pb2.py

Created August 11, 2020 07:28
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save simon-mo/bb2476d5bd201a9adbd186519275ec24 to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save simon-mo/bb2476d5bd201a9adbd186519275ec24 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
common_pb2.py
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: src/ray/protobuf/common.proto
import sys
_b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1'))
from google.protobuf.internal import enum_type_wrapper
from google.protobuf import descriptor as _descriptor
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()
DESCRIPTOR = _descriptor.FileDescriptor(
name='src/ray/protobuf/common.proto',
package='ray.rpc',
syntax='proto3',
serialized_options=_b('\n\030io.ray.runtime.generated'),
serialized_pb=_b('\n\x1dsrc/ray/protobuf/common.proto\x12\x07ray.rpc\"v\n\x07\x41\x64\x64ress\x12\x1b\n\traylet_id\x18\x01 \x01(\x0cR\x08rayletId\x12\x1d\n\nip_address\x18\x02 \x01(\tR\tipAddress\x12\x12\n\x04port\x18\x03 \x01(\x05R\x04port\x12\x1b\n\tworker_id\x18\x04 \x01(\x0cR\x08workerId\"z\n\x16JavaFunctionDescriptor\x12\x1d\n\nclass_name\x18\x01 \x01(\tR\tclassName\x12#\n\rfunction_name\x18\x02 \x01(\tR\x0c\x66unctionName\x12\x1c\n\tsignature\x18\x03 \x01(\tR\tsignature\"\xa4\x01\n\x18PythonFunctionDescriptor\x12\x1f\n\x0bmodule_name\x18\x01 \x01(\tR\nmoduleName\x12\x1d\n\nclass_name\x18\x02 \x01(\tR\tclassName\x12#\n\rfunction_name\x18\x03 \x01(\tR\x0c\x66unctionName\x12#\n\rfunction_hash\x18\x04 \x01(\tR\x0c\x66unctionHash\"\x8d\x01\n\x15\x43ppFunctionDescriptor\x12\x19\n\x08lib_name\x18\x01 \x01(\tR\x07libName\x12\'\n\x0f\x66unction_offset\x18\x02 \x01(\tR\x0e\x66unctionOffset\x12\x30\n\x14\x65xec_function_offset\x18\x03 \x01(\tR\x12\x65xecFunctionOffset\"\xc5\x02\n\x12\x46unctionDescriptor\x12[\n\x18java_function_descriptor\x18\x01 \x01(\x0b\x32\x1f.ray.rpc.JavaFunctionDescriptorH\x00R\x16javaFunctionDescriptor\x12\x61\n\x1apython_function_descriptor\x18\x02 \x01(\x0b\x32!.ray.rpc.PythonFunctionDescriptorH\x00R\x18pythonFunctionDescriptor\x12X\n\x17\x63pp_function_descriptor\x18\x03 \x01(\x0b\x32\x1e.ray.rpc.CppFunctionDescriptorH\x00R\x15\x63ppFunctionDescriptorB\x15\n\x13\x66unction_descriptor\"\xe5\x07\n\x08TaskSpec\x12%\n\x04type\x18\x01 \x01(\x0e\x32\x11.ray.rpc.TaskTypeR\x04type\x12-\n\x08language\x18\x02 \x01(\x0e\x32\x11.ray.rpc.LanguageR\x08language\x12L\n\x13\x66unction_descriptor\x18\x03 \x01(\x0b\x32\x1b.ray.rpc.FunctionDescriptorR\x12\x66unctionDescriptor\x12\x15\n\x06job_id\x18\x04 \x01(\x0cR\x05jobId\x12\x17\n\x07task_id\x18\x05 \x01(\x0cR\x06taskId\x12$\n\x0eparent_task_id\x18\x06 \x01(\x0cR\x0cparentTaskId\x12%\n\x0eparent_counter\x18\x07 \x01(\x04R\rparentCounter\x12\x1b\n\tcaller_id\x18\x08 \x01(\x0cR\x08\x63\x61llerId\x12\x37\n\x0e\x63\x61ller_address\x18\t \x01(\x0b\x32\x10.ray.rpc.AddressR\rcallerAddress\x12$\n\x04\x61rgs\x18\n \x03(\x0b\x32\x10.ray.rpc.TaskArgR\x04\x61rgs\x12\x1f\n\x0bnum_returns\x18\x0b \x01(\x04R\nnumReturns\x12W\n\x12required_resources\x18\x0c \x03(\x0b\x32(.ray.rpc.TaskSpec.RequiredResourcesEntryR\x11requiredResources\x12s\n\x1crequired_placement_resources\x18\r \x03(\x0b\x32\x31.ray.rpc.TaskSpec.RequiredPlacementResourcesEntryR\x1arequiredPlacementResources\x12W\n\x18\x61\x63tor_creation_task_spec\x18\x0e \x01(\x0b\x32\x1e.ray.rpc.ActorCreationTaskSpecR\x15\x61\x63torCreationTaskSpec\x12>\n\x0f\x61\x63tor_task_spec\x18\x0f \x01(\x0b\x32\x16.ray.rpc.ActorTaskSpecR\ractorTaskSpec\x12\x1f\n\x0bmax_retries\x18\x10 \x01(\x05R\nmaxRetries\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\x1aM\n\x1fRequiredPlacementResourcesEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\x01R\x05value:\x02\x38\x01\"\xb9\x02\n\x06\x42undle\x12=\n\tbundle_id\x18\x01 \x01(\x0b\x32 .ray.rpc.Bundle.BundleIdentifierR\x08\x62undleId\x12I\n\x0eunit_resources\x18\x02 \x03(\x0b\x32\".ray.rpc.Bundle.UnitResourcesEntryR\runitResources\x1a\x63\n\x10\x42undleIdentifier\x12,\n\x12placement_group_id\x18\x01 \x01(\x0cR\x10placementGroupId\x12!\n\x0c\x62undle_index\x18\x02 \x01(\x05R\x0b\x62undleIndex\x1a@\n\x12UnitResourcesEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\x01R\x05value:\x02\x38\x01\"\xb9\x01\n\x12PlacementGroupSpec\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\"e\n\x0fObjectReference\x12\x1b\n\tobject_id\x18\x01 \x01(\x0cR\x08objectId\x12\x35\n\rowner_address\x18\x02 \x01(\x0b\x32\x10.ray.rpc.AddressR\x0cownerAddress\"\xa0\x01\n\x07TaskArg\x12\x37\n\nobject_ref\x18\x01 \x01(\x0b\x32\x18.ray.rpc.ObjectReferenceR\tobjectRef\x12\x12\n\x04\x64\x61ta\x18\x02 \x01(\x0cR\x04\x64\x61ta\x12\x1a\n\x08metadata\x18\x03 \x01(\x0cR\x08metadata\x12,\n\x12nested_inlined_ids\x18\x04 \x03(\x0cR\x10nestedInlinedIds\"\xba\x02\n\x15\x41\x63torCreationTaskSpec\x12\x19\n\x08\x61\x63tor_id\x18\x02 \x01(\x0cR\x07\x61\x63torId\x12,\n\x12max_actor_restarts\x18\x03 \x01(\x03R\x10maxActorRestarts\x12\x34\n\x16\x64ynamic_worker_options\x18\x04 \x03(\tR\x14\x64ynamicWorkerOptions\x12\'\n\x0fmax_concurrency\x18\x05 \x01(\x05R\x0emaxConcurrency\x12\x1f\n\x0bis_detached\x18\x06 \x01(\x08R\nisDetached\x12\x12\n\x04name\x18\x07 \x01(\tR\x04name\x12\x1d\n\nis_asyncio\x18\x08 \x01(\x08R\tisAsyncio\x12%\n\x0e\x65xtension_data\x18\t \x01(\tR\rextensionData\"\xe0\x01\n\rActorTaskSpec\x12\x19\n\x08\x61\x63tor_id\x18\x02 \x01(\x0cR\x07\x61\x63torId\x12\x42\n\x1e\x61\x63tor_creation_dummy_object_id\x18\x04 \x01(\x0cR\x1a\x61\x63torCreationDummyObjectId\x12#\n\ractor_counter\x18\x05 \x01(\x04R\x0c\x61\x63torCounter\x12K\n#previous_actor_task_dummy_object_id\x18\x07 \x01(\x0cR\x1epreviousActorTaskDummyObjectId\"]\n\x11TaskExecutionSpec\x12%\n\x0elast_timestamp\x18\x02 \x01(\x01R\rlastTimestamp\x12!\n\x0cnum_forwards\x18\x03 \x01(\x04R\x0bnumForwards\"\x82\x01\n\x04Task\x12.\n\ttask_spec\x18\x01 \x01(\x0b\x32\x11.ray.rpc.TaskSpecR\x08taskSpec\x12J\n\x13task_execution_spec\x18\x02 \x01(\x0b\x32\x1a.ray.rpc.TaskExecutionSpecR\x11taskExecutionSpec\">\n\nResourceId\x12\x14\n\x05index\x18\x01 \x01(\x03R\x05index\x12\x1a\n\x08quantity\x18\x02 \x01(\x01R\x08quantity\"^\n\x10ResourceMapEntry\x12\x12\n\x04name\x18\x01 \x01(\tR\x04name\x12\x36\n\x0cresource_ids\x18\x02 \x03(\x0b\x32\x13.ray.rpc.ResourceIdR\x0bresourceIds\"\xf4\x03\n\x08ViewData\x12\x1b\n\tview_name\x18\x01 \x01(\tR\x08viewName\x12\x35\n\x08measures\x18\x02 \x03(\x0b\x32\x19.ray.rpc.ViewData.MeasureR\x08measures\x1a\x93\x03\n\x07Measure\x12\x12\n\x04tags\x18\x01 \x01(\tR\x04tags\x12\x1b\n\tint_value\x18\x02 \x01(\x03R\x08intValue\x12!\n\x0c\x64ouble_value\x18\x03 \x01(\x01R\x0b\x64oubleValue\x12)\n\x10\x64istribution_min\x18\x04 \x01(\x01R\x0f\x64istributionMin\x12+\n\x11\x64istribution_mean\x18\x05 \x01(\x01R\x10\x64istributionMean\x12)\n\x10\x64istribution_max\x18\x06 \x01(\x01R\x0f\x64istributionMax\x12-\n\x12\x64istribution_count\x18\x07 \x01(\x01R\x11\x64istributionCount\x12\x44\n\x1e\x64istribution_bucket_boundaries\x18\x08 \x03(\x01R\x1c\x64istributionBucketBoundaries\x12<\n\x1a\x64istribution_bucket_counts\x18\t \x03(\x01R\x18\x64istributionBucketCounts\"\xa3\x02\n\rObjectRefInfo\x12\x1b\n\tobject_id\x18\x01 \x01(\x0cR\x08objectId\x12\x1b\n\tcall_site\x18\x02 \x01(\tR\x08\x63\x61llSite\x12\x1f\n\x0bobject_size\x18\x03 \x01(\x03R\nobjectSize\x12&\n\x0flocal_ref_count\x18\x04 \x01(\x03R\rlocalRefCount\x12\x37\n\x18submitted_task_ref_count\x18\x05 \x01(\x03R\x15submittedTaskRefCount\x12,\n\x12\x63ontained_in_owned\x18\x06 \x03(\x0cR\x10\x63ontainedInOwned\x12(\n\x10pinned_in_memory\x18\x07 \x01(\x08R\x0epinnedInMemory\"\xab\x01\n\x13ResourceAllocations\x12P\n\x0eresource_slots\x18\x01 \x03(\x0b\x32).ray.rpc.ResourceAllocations.ResourceSlotR\rresourceSlots\x1a\x42\n\x0cResourceSlot\x12\x12\n\x04slot\x18\x01 \x01(\x03R\x04slot\x12\x1e\n\nallocation\x18\x02 \x01(\x01R\nallocation\"\xa7\x07\n\x0f\x43oreWorkerStats\x12*\n\x11\x63urrent_task_desc\x18\x01 \x01(\tR\x0f\x63urrentTaskDesc\x12*\n\x11num_pending_tasks\x18\x02 \x01(\x05R\x0fnumPendingTasks\x12\x36\n\x18num_object_refs_in_scope\x18\x03 \x01(\x05R\x14numObjectRefsInScope\x12\x33\n\x16\x63urrent_task_func_desc\x18\x04 \x01(\tR\x13\x63urrentTaskFuncDesc\x12\x1d\n\nip_address\x18\x06 \x01(\tR\tipAddress\x12\x12\n\x04port\x18\x07 \x01(\x03R\x04port\x12\x19\n\x08\x61\x63tor_id\x18\x08 \x01(\x0cR\x07\x61\x63torId\x12R\n\x0eused_resources\x18\t \x03(\x0b\x32+.ray.rpc.CoreWorkerStats.UsedResourcesEntryR\rusedResources\x12O\n\rwebui_display\x18\n \x03(\x0b\x32*.ray.rpc.CoreWorkerStats.WebuiDisplayEntryR\x0cwebuiDisplay\x12\"\n\rnum_in_plasma\x18\x0b \x01(\x05R\x0bnumInPlasma\x12*\n\x11num_local_objects\x18\x0c \x01(\x05R\x0fnumLocalObjects\x12\x37\n\x18used_object_store_memory\x18\r \x01(\x03R\x15usedObjectStoreMemory\x12*\n\x11task_queue_length\x18\x0e \x01(\x05R\x0ftaskQueueLength\x12,\n\x12num_executed_tasks\x18\x0f \x01(\x05R\x10numExecutedTasks\x12\x1f\n\x0b\x61\x63tor_title\x18\x10 \x01(\tR\nactorTitle\x12\x37\n\x0bobject_refs\x18\x11 \x03(\x0b\x32\x16.ray.rpc.ObjectRefInfoR\nobjectRefs\x1a^\n\x12UsedResourcesEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x32\n\x05value\x18\x02 \x01(\x0b\x32\x1c.ray.rpc.ResourceAllocationsR\x05value:\x02\x38\x01\x1a?\n\x11WebuiDisplayEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\"\x87\x02\n\x0bMetricPoint\x12\x1f\n\x0bmetric_name\x18\x01 \x01(\tR\nmetricName\x12\x1c\n\ttimestamp\x18\x02 \x01(\x03R\ttimestamp\x12\x14\n\x05value\x18\x03 \x01(\x01R\x05value\x12\x32\n\x04tags\x18\x04 \x03(\x0b\x32\x1e.ray.rpc.MetricPoint.TagsEntryR\x04tags\x12 \n\x0b\x64\x65scription\x18\x05 \x01(\tR\x0b\x64\x65scription\x12\x14\n\x05units\x18\x06 \x01(\tR\x05units\x1a\x37\n\tTagsEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01*)\n\x08Language\x12\n\n\x06PYTHON\x10\x00\x12\x08\n\x04JAVA\x10\x01\x12\x07\n\x03\x43PP\x10\x02*$\n\nWorkerType\x12\n\n\x06WORKER\x10\x00\x12\n\n\x06\x44RIVER\x10\x01*U\n\x08TaskType\x12\x0f\n\x0bNORMAL_TASK\x10\x00\x12\x17\n\x13\x41\x43TOR_CREATION_TASK\x10\x01\x12\x0e\n\nACTOR_TASK\x10\x02\x12\x0f\n\x0b\x44RIVER_TASK\x10\x03*)\n\x11PlacementStrategy\x12\x08\n\x04PACK\x10\x00\x12\n\n\x06SPREAD\x10\x01\x42\x1a\n\x18io.ray.runtime.generatedb\x06proto3')
)
_LANGUAGE = _descriptor.EnumDescriptor(
name='Language',
full_name='ray.rpc.Language',
filename=None,
file=DESCRIPTOR,
values=[
_descriptor.EnumValueDescriptor(
name='PYTHON', index=0, number=0,
serialized_options=None,
type=None),
_descriptor.EnumValueDescriptor(
name='JAVA', index=1, number=1,
serialized_options=None,
type=None),
_descriptor.EnumValueDescriptor(
name='CPP', index=2, number=2,
serialized_options=None,
type=None),
],
containing_type=None,
serialized_options=None,
serialized_start=5802,
serialized_end=5843,
)
_sym_db.RegisterEnumDescriptor(_LANGUAGE)
Language = enum_type_wrapper.EnumTypeWrapper(_LANGUAGE)
_WORKERTYPE = _descriptor.EnumDescriptor(
name='WorkerType',
full_name='ray.rpc.WorkerType',
filename=None,
file=DESCRIPTOR,
values=[
_descriptor.EnumValueDescriptor(
name='WORKER', index=0, number=0,
serialized_options=None,
type=None),
_descriptor.EnumValueDescriptor(
name='DRIVER', index=1, number=1,
serialized_options=None,
type=None),
],
containing_type=None,
serialized_options=None,
serialized_start=5845,
serialized_end=5881,
)
_sym_db.RegisterEnumDescriptor(_WORKERTYPE)
WorkerType = enum_type_wrapper.EnumTypeWrapper(_WORKERTYPE)
_TASKTYPE = _descriptor.EnumDescriptor(
name='TaskType',
full_name='ray.rpc.TaskType',
filename=None,
file=DESCRIPTOR,
values=[
_descriptor.EnumValueDescriptor(
name='NORMAL_TASK', index=0, number=0,
serialized_options=None,
type=None),
_descriptor.EnumValueDescriptor(
name='ACTOR_CREATION_TASK', index=1, number=1,
serialized_options=None,
type=None),
_descriptor.EnumValueDescriptor(
name='ACTOR_TASK', index=2, number=2,
serialized_options=None,
type=None),
_descriptor.EnumValueDescriptor(
name='DRIVER_TASK', index=3, number=3,
serialized_options=None,
type=None),
],
containing_type=None,
serialized_options=None,
serialized_start=5883,
serialized_end=5968,
)
_sym_db.RegisterEnumDescriptor(_TASKTYPE)
TaskType = enum_type_wrapper.EnumTypeWrapper(_TASKTYPE)
_PLACEMENTSTRATEGY = _descriptor.EnumDescriptor(
name='PlacementStrategy',
full_name='ray.rpc.PlacementStrategy',
filename=None,
file=DESCRIPTOR,
values=[
_descriptor.EnumValueDescriptor(
name='PACK', index=0, number=0,
serialized_options=None,
type=None),
_descriptor.EnumValueDescriptor(
name='SPREAD', index=1, number=1,
serialized_options=None,
type=None),
],
containing_type=None,
serialized_options=None,
serialized_start=5970,
serialized_end=6011,
)
_sym_db.RegisterEnumDescriptor(_PLACEMENTSTRATEGY)
PlacementStrategy = enum_type_wrapper.EnumTypeWrapper(_PLACEMENTSTRATEGY)
PYTHON = 0
JAVA = 1
CPP = 2
WORKER = 0
DRIVER = 1
NORMAL_TASK = 0
ACTOR_CREATION_TASK = 1
ACTOR_TASK = 2
DRIVER_TASK = 3
PACK = 0
SPREAD = 1
_ADDRESS = _descriptor.Descriptor(
name='Address',
full_name='ray.rpc.Address',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='raylet_id', full_name='ray.rpc.Address.raylet_id', index=0,
number=1, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='rayletId', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='ip_address', full_name='ray.rpc.Address.ip_address', index=1,
number=2, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='ipAddress', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='port', full_name='ray.rpc.Address.port', index=2,
number=3, type=5, cpp_type=1, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='port', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='worker_id', full_name='ray.rpc.Address.worker_id', index=3,
number=4, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='workerId', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=42,
serialized_end=160,
)
_JAVAFUNCTIONDESCRIPTOR = _descriptor.Descriptor(
name='JavaFunctionDescriptor',
full_name='ray.rpc.JavaFunctionDescriptor',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='class_name', full_name='ray.rpc.JavaFunctionDescriptor.class_name', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='className', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='function_name', full_name='ray.rpc.JavaFunctionDescriptor.function_name', index=1,
number=2, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='functionName', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='signature', full_name='ray.rpc.JavaFunctionDescriptor.signature', index=2,
number=3, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='signature', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=162,
serialized_end=284,
)
_PYTHONFUNCTIONDESCRIPTOR = _descriptor.Descriptor(
name='PythonFunctionDescriptor',
full_name='ray.rpc.PythonFunctionDescriptor',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='module_name', full_name='ray.rpc.PythonFunctionDescriptor.module_name', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='moduleName', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='class_name', full_name='ray.rpc.PythonFunctionDescriptor.class_name', index=1,
number=2, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='className', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='function_name', full_name='ray.rpc.PythonFunctionDescriptor.function_name', index=2,
number=3, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='functionName', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='function_hash', full_name='ray.rpc.PythonFunctionDescriptor.function_hash', index=3,
number=4, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='functionHash', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=287,
serialized_end=451,
)
_CPPFUNCTIONDESCRIPTOR = _descriptor.Descriptor(
name='CppFunctionDescriptor',
full_name='ray.rpc.CppFunctionDescriptor',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='lib_name', full_name='ray.rpc.CppFunctionDescriptor.lib_name', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='libName', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='function_offset', full_name='ray.rpc.CppFunctionDescriptor.function_offset', index=1,
number=2, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='functionOffset', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='exec_function_offset', full_name='ray.rpc.CppFunctionDescriptor.exec_function_offset', index=2,
number=3, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='execFunctionOffset', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=454,
serialized_end=595,
)
_FUNCTIONDESCRIPTOR = _descriptor.Descriptor(
name='FunctionDescriptor',
full_name='ray.rpc.FunctionDescriptor',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='java_function_descriptor', full_name='ray.rpc.FunctionDescriptor.java_function_descriptor', index=0,
number=1, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='javaFunctionDescriptor', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='python_function_descriptor', full_name='ray.rpc.FunctionDescriptor.python_function_descriptor', index=1,
number=2, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='pythonFunctionDescriptor', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='cpp_function_descriptor', full_name='ray.rpc.FunctionDescriptor.cpp_function_descriptor', index=2,
number=3, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='cppFunctionDescriptor', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
_descriptor.OneofDescriptor(
name='function_descriptor', full_name='ray.rpc.FunctionDescriptor.function_descriptor',
index=0, containing_type=None, fields=[]),
],
serialized_start=598,
serialized_end=923,
)
_TASKSPEC_REQUIREDRESOURCESENTRY = _descriptor.Descriptor(
name='RequiredResourcesEntry',
full_name='ray.rpc.TaskSpec.RequiredResourcesEntry',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='key', full_name='ray.rpc.TaskSpec.RequiredResourcesEntry.key', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='key', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='value', full_name='ray.rpc.TaskSpec.RequiredResourcesEntry.value', index=1,
number=2, type=1, cpp_type=5, label=1,
has_default_value=False, default_value=float(0),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='value', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=_b('8\001'),
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=1776,
serialized_end=1844,
)
_TASKSPEC_REQUIREDPLACEMENTRESOURCESENTRY = _descriptor.Descriptor(
name='RequiredPlacementResourcesEntry',
full_name='ray.rpc.TaskSpec.RequiredPlacementResourcesEntry',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='key', full_name='ray.rpc.TaskSpec.RequiredPlacementResourcesEntry.key', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='key', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='value', full_name='ray.rpc.TaskSpec.RequiredPlacementResourcesEntry.value', index=1,
number=2, type=1, cpp_type=5, label=1,
has_default_value=False, default_value=float(0),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='value', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=_b('8\001'),
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=1846,
serialized_end=1923,
)
_TASKSPEC = _descriptor.Descriptor(
name='TaskSpec',
full_name='ray.rpc.TaskSpec',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='type', full_name='ray.rpc.TaskSpec.type', index=0,
number=1, type=14, cpp_type=8, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='type', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='language', full_name='ray.rpc.TaskSpec.language', index=1,
number=2, type=14, cpp_type=8, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='language', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='function_descriptor', full_name='ray.rpc.TaskSpec.function_descriptor', index=2,
number=3, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='functionDescriptor', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='job_id', full_name='ray.rpc.TaskSpec.job_id', index=3,
number=4, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='jobId', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='task_id', full_name='ray.rpc.TaskSpec.task_id', index=4,
number=5, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='taskId', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='parent_task_id', full_name='ray.rpc.TaskSpec.parent_task_id', index=5,
number=6, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='parentTaskId', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='parent_counter', full_name='ray.rpc.TaskSpec.parent_counter', index=6,
number=7, type=4, cpp_type=4, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='parentCounter', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='caller_id', full_name='ray.rpc.TaskSpec.caller_id', index=7,
number=8, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='callerId', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='caller_address', full_name='ray.rpc.TaskSpec.caller_address', index=8,
number=9, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='callerAddress', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='args', full_name='ray.rpc.TaskSpec.args', index=9,
number=10, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='args', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='num_returns', full_name='ray.rpc.TaskSpec.num_returns', index=10,
number=11, type=4, cpp_type=4, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='numReturns', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='required_resources', full_name='ray.rpc.TaskSpec.required_resources', index=11,
number=12, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='requiredResources', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='required_placement_resources', full_name='ray.rpc.TaskSpec.required_placement_resources', index=12,
number=13, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='requiredPlacementResources', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='actor_creation_task_spec', full_name='ray.rpc.TaskSpec.actor_creation_task_spec', index=13,
number=14, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='actorCreationTaskSpec', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='actor_task_spec', full_name='ray.rpc.TaskSpec.actor_task_spec', index=14,
number=15, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='actorTaskSpec', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='max_retries', full_name='ray.rpc.TaskSpec.max_retries', index=15,
number=16, type=5, cpp_type=1, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='maxRetries', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[_TASKSPEC_REQUIREDRESOURCESENTRY, _TASKSPEC_REQUIREDPLACEMENTRESOURCESENTRY, ],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=926,
serialized_end=1923,
)
_BUNDLE_BUNDLEIDENTIFIER = _descriptor.Descriptor(
name='BundleIdentifier',
full_name='ray.rpc.Bundle.BundleIdentifier',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='placement_group_id', full_name='ray.rpc.Bundle.BundleIdentifier.placement_group_id', index=0,
number=1, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='placementGroupId', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='bundle_index', full_name='ray.rpc.Bundle.BundleIdentifier.bundle_index', index=1,
number=2, type=5, cpp_type=1, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='bundleIndex', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=2074,
serialized_end=2173,
)
_BUNDLE_UNITRESOURCESENTRY = _descriptor.Descriptor(
name='UnitResourcesEntry',
full_name='ray.rpc.Bundle.UnitResourcesEntry',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='key', full_name='ray.rpc.Bundle.UnitResourcesEntry.key', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='key', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='value', full_name='ray.rpc.Bundle.UnitResourcesEntry.value', index=1,
number=2, type=1, cpp_type=5, label=1,
has_default_value=False, default_value=float(0),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='value', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=_b('8\001'),
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=2175,
serialized_end=2239,
)
_BUNDLE = _descriptor.Descriptor(
name='Bundle',
full_name='ray.rpc.Bundle',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='bundle_id', full_name='ray.rpc.Bundle.bundle_id', index=0,
number=1, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='bundleId', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='unit_resources', full_name='ray.rpc.Bundle.unit_resources', index=1,
number=2, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='unitResources', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[_BUNDLE_BUNDLEIDENTIFIER, _BUNDLE_UNITRESOURCESENTRY, ],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=1926,
serialized_end=2239,
)
_PLACEMENTGROUPSPEC = _descriptor.Descriptor(
name='PlacementGroupSpec',
full_name='ray.rpc.PlacementGroupSpec',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='placement_group_id', full_name='ray.rpc.PlacementGroupSpec.placement_group_id', index=0,
number=1, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='placementGroupId', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='name', full_name='ray.rpc.PlacementGroupSpec.name', index=1,
number=2, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='name', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='bundles', full_name='ray.rpc.PlacementGroupSpec.bundles', index=2,
number=3, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='bundles', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='strategy', full_name='ray.rpc.PlacementGroupSpec.strategy', index=3,
number=4, type=14, cpp_type=8, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='strategy', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=2242,
serialized_end=2427,
)
_OBJECTREFERENCE = _descriptor.Descriptor(
name='ObjectReference',
full_name='ray.rpc.ObjectReference',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='object_id', full_name='ray.rpc.ObjectReference.object_id', index=0,
number=1, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='objectId', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='owner_address', full_name='ray.rpc.ObjectReference.owner_address', index=1,
number=2, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='ownerAddress', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=2429,
serialized_end=2530,
)
_TASKARG = _descriptor.Descriptor(
name='TaskArg',
full_name='ray.rpc.TaskArg',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='object_ref', full_name='ray.rpc.TaskArg.object_ref', index=0,
number=1, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='objectRef', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='data', full_name='ray.rpc.TaskArg.data', index=1,
number=2, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='data', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='metadata', full_name='ray.rpc.TaskArg.metadata', index=2,
number=3, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='metadata', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='nested_inlined_ids', full_name='ray.rpc.TaskArg.nested_inlined_ids', index=3,
number=4, type=12, cpp_type=9, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='nestedInlinedIds', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=2533,
serialized_end=2693,
)
_ACTORCREATIONTASKSPEC = _descriptor.Descriptor(
name='ActorCreationTaskSpec',
full_name='ray.rpc.ActorCreationTaskSpec',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='actor_id', full_name='ray.rpc.ActorCreationTaskSpec.actor_id', index=0,
number=2, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='actorId', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='max_actor_restarts', full_name='ray.rpc.ActorCreationTaskSpec.max_actor_restarts', index=1,
number=3, type=3, cpp_type=2, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='maxActorRestarts', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='dynamic_worker_options', full_name='ray.rpc.ActorCreationTaskSpec.dynamic_worker_options', index=2,
number=4, type=9, cpp_type=9, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='dynamicWorkerOptions', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='max_concurrency', full_name='ray.rpc.ActorCreationTaskSpec.max_concurrency', index=3,
number=5, type=5, cpp_type=1, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='maxConcurrency', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='is_detached', full_name='ray.rpc.ActorCreationTaskSpec.is_detached', index=4,
number=6, type=8, cpp_type=7, label=1,
has_default_value=False, default_value=False,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='isDetached', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='name', full_name='ray.rpc.ActorCreationTaskSpec.name', index=5,
number=7, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='name', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='is_asyncio', full_name='ray.rpc.ActorCreationTaskSpec.is_asyncio', index=6,
number=8, type=8, cpp_type=7, label=1,
has_default_value=False, default_value=False,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='isAsyncio', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='extension_data', full_name='ray.rpc.ActorCreationTaskSpec.extension_data', index=7,
number=9, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='extensionData', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=2696,
serialized_end=3010,
)
_ACTORTASKSPEC = _descriptor.Descriptor(
name='ActorTaskSpec',
full_name='ray.rpc.ActorTaskSpec',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='actor_id', full_name='ray.rpc.ActorTaskSpec.actor_id', index=0,
number=2, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='actorId', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='actor_creation_dummy_object_id', full_name='ray.rpc.ActorTaskSpec.actor_creation_dummy_object_id', index=1,
number=4, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='actorCreationDummyObjectId', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='actor_counter', full_name='ray.rpc.ActorTaskSpec.actor_counter', index=2,
number=5, type=4, cpp_type=4, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='actorCounter', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='previous_actor_task_dummy_object_id', full_name='ray.rpc.ActorTaskSpec.previous_actor_task_dummy_object_id', index=3,
number=7, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='previousActorTaskDummyObjectId', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=3013,
serialized_end=3237,
)
_TASKEXECUTIONSPEC = _descriptor.Descriptor(
name='TaskExecutionSpec',
full_name='ray.rpc.TaskExecutionSpec',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='last_timestamp', full_name='ray.rpc.TaskExecutionSpec.last_timestamp', index=0,
number=2, type=1, cpp_type=5, label=1,
has_default_value=False, default_value=float(0),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='lastTimestamp', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='num_forwards', full_name='ray.rpc.TaskExecutionSpec.num_forwards', index=1,
number=3, type=4, cpp_type=4, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='numForwards', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=3239,
serialized_end=3332,
)
_TASK = _descriptor.Descriptor(
name='Task',
full_name='ray.rpc.Task',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='task_spec', full_name='ray.rpc.Task.task_spec', index=0,
number=1, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='taskSpec', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='task_execution_spec', full_name='ray.rpc.Task.task_execution_spec', index=1,
number=2, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='taskExecutionSpec', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=3335,
serialized_end=3465,
)
_RESOURCEID = _descriptor.Descriptor(
name='ResourceId',
full_name='ray.rpc.ResourceId',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='index', full_name='ray.rpc.ResourceId.index', index=0,
number=1, type=3, cpp_type=2, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='index', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='quantity', full_name='ray.rpc.ResourceId.quantity', index=1,
number=2, type=1, cpp_type=5, label=1,
has_default_value=False, default_value=float(0),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='quantity', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=3467,
serialized_end=3529,
)
_RESOURCEMAPENTRY = _descriptor.Descriptor(
name='ResourceMapEntry',
full_name='ray.rpc.ResourceMapEntry',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='name', full_name='ray.rpc.ResourceMapEntry.name', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='name', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='resource_ids', full_name='ray.rpc.ResourceMapEntry.resource_ids', index=1,
number=2, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='resourceIds', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=3531,
serialized_end=3625,
)
_VIEWDATA_MEASURE = _descriptor.Descriptor(
name='Measure',
full_name='ray.rpc.ViewData.Measure',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='tags', full_name='ray.rpc.ViewData.Measure.tags', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='tags', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='int_value', full_name='ray.rpc.ViewData.Measure.int_value', index=1,
number=2, type=3, cpp_type=2, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='intValue', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='double_value', full_name='ray.rpc.ViewData.Measure.double_value', index=2,
number=3, type=1, cpp_type=5, label=1,
has_default_value=False, default_value=float(0),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='doubleValue', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='distribution_min', full_name='ray.rpc.ViewData.Measure.distribution_min', index=3,
number=4, type=1, cpp_type=5, label=1,
has_default_value=False, default_value=float(0),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='distributionMin', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='distribution_mean', full_name='ray.rpc.ViewData.Measure.distribution_mean', index=4,
number=5, type=1, cpp_type=5, label=1,
has_default_value=False, default_value=float(0),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='distributionMean', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='distribution_max', full_name='ray.rpc.ViewData.Measure.distribution_max', index=5,
number=6, type=1, cpp_type=5, label=1,
has_default_value=False, default_value=float(0),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='distributionMax', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='distribution_count', full_name='ray.rpc.ViewData.Measure.distribution_count', index=6,
number=7, type=1, cpp_type=5, label=1,
has_default_value=False, default_value=float(0),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='distributionCount', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='distribution_bucket_boundaries', full_name='ray.rpc.ViewData.Measure.distribution_bucket_boundaries', index=7,
number=8, type=1, cpp_type=5, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='distributionBucketBoundaries', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='distribution_bucket_counts', full_name='ray.rpc.ViewData.Measure.distribution_bucket_counts', index=8,
number=9, type=1, cpp_type=5, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='distributionBucketCounts', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=3725,
serialized_end=4128,
)
_VIEWDATA = _descriptor.Descriptor(
name='ViewData',
full_name='ray.rpc.ViewData',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='view_name', full_name='ray.rpc.ViewData.view_name', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='viewName', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='measures', full_name='ray.rpc.ViewData.measures', index=1,
number=2, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='measures', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[_VIEWDATA_MEASURE, ],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=3628,
serialized_end=4128,
)
_OBJECTREFINFO = _descriptor.Descriptor(
name='ObjectRefInfo',
full_name='ray.rpc.ObjectRefInfo',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='object_id', full_name='ray.rpc.ObjectRefInfo.object_id', index=0,
number=1, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='objectId', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='call_site', full_name='ray.rpc.ObjectRefInfo.call_site', index=1,
number=2, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='callSite', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='object_size', full_name='ray.rpc.ObjectRefInfo.object_size', index=2,
number=3, type=3, cpp_type=2, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='objectSize', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='local_ref_count', full_name='ray.rpc.ObjectRefInfo.local_ref_count', index=3,
number=4, type=3, cpp_type=2, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='localRefCount', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='submitted_task_ref_count', full_name='ray.rpc.ObjectRefInfo.submitted_task_ref_count', index=4,
number=5, type=3, cpp_type=2, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='submittedTaskRefCount', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='contained_in_owned', full_name='ray.rpc.ObjectRefInfo.contained_in_owned', index=5,
number=6, type=12, cpp_type=9, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='containedInOwned', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='pinned_in_memory', full_name='ray.rpc.ObjectRefInfo.pinned_in_memory', index=6,
number=7, type=8, cpp_type=7, label=1,
has_default_value=False, default_value=False,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='pinnedInMemory', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=4131,
serialized_end=4422,
)
_RESOURCEALLOCATIONS_RESOURCESLOT = _descriptor.Descriptor(
name='ResourceSlot',
full_name='ray.rpc.ResourceAllocations.ResourceSlot',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='slot', full_name='ray.rpc.ResourceAllocations.ResourceSlot.slot', index=0,
number=1, type=3, cpp_type=2, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='slot', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='allocation', full_name='ray.rpc.ResourceAllocations.ResourceSlot.allocation', index=1,
number=2, type=1, cpp_type=5, label=1,
has_default_value=False, default_value=float(0),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='allocation', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=4530,
serialized_end=4596,
)
_RESOURCEALLOCATIONS = _descriptor.Descriptor(
name='ResourceAllocations',
full_name='ray.rpc.ResourceAllocations',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='resource_slots', full_name='ray.rpc.ResourceAllocations.resource_slots', index=0,
number=1, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='resourceSlots', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[_RESOURCEALLOCATIONS_RESOURCESLOT, ],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=4425,
serialized_end=4596,
)
_COREWORKERSTATS_USEDRESOURCESENTRY = _descriptor.Descriptor(
name='UsedResourcesEntry',
full_name='ray.rpc.CoreWorkerStats.UsedResourcesEntry',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='key', full_name='ray.rpc.CoreWorkerStats.UsedResourcesEntry.key', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='key', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='value', full_name='ray.rpc.CoreWorkerStats.UsedResourcesEntry.value', index=1,
number=2, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='value', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=_b('8\001'),
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=5375,
serialized_end=5469,
)
_COREWORKERSTATS_WEBUIDISPLAYENTRY = _descriptor.Descriptor(
name='WebuiDisplayEntry',
full_name='ray.rpc.CoreWorkerStats.WebuiDisplayEntry',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='key', full_name='ray.rpc.CoreWorkerStats.WebuiDisplayEntry.key', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='key', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='value', full_name='ray.rpc.CoreWorkerStats.WebuiDisplayEntry.value', index=1,
number=2, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='value', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=_b('8\001'),
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=5471,
serialized_end=5534,
)
_COREWORKERSTATS = _descriptor.Descriptor(
name='CoreWorkerStats',
full_name='ray.rpc.CoreWorkerStats',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='current_task_desc', full_name='ray.rpc.CoreWorkerStats.current_task_desc', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='currentTaskDesc', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='num_pending_tasks', full_name='ray.rpc.CoreWorkerStats.num_pending_tasks', index=1,
number=2, type=5, cpp_type=1, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='numPendingTasks', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='num_object_refs_in_scope', full_name='ray.rpc.CoreWorkerStats.num_object_refs_in_scope', index=2,
number=3, type=5, cpp_type=1, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='numObjectRefsInScope', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='current_task_func_desc', full_name='ray.rpc.CoreWorkerStats.current_task_func_desc', index=3,
number=4, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='currentTaskFuncDesc', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='ip_address', full_name='ray.rpc.CoreWorkerStats.ip_address', index=4,
number=6, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='ipAddress', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='port', full_name='ray.rpc.CoreWorkerStats.port', index=5,
number=7, type=3, cpp_type=2, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='port', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='actor_id', full_name='ray.rpc.CoreWorkerStats.actor_id', index=6,
number=8, type=12, cpp_type=9, label=1,
has_default_value=False, default_value=_b(""),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='actorId', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='used_resources', full_name='ray.rpc.CoreWorkerStats.used_resources', index=7,
number=9, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='usedResources', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='webui_display', full_name='ray.rpc.CoreWorkerStats.webui_display', index=8,
number=10, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='webuiDisplay', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='num_in_plasma', full_name='ray.rpc.CoreWorkerStats.num_in_plasma', index=9,
number=11, type=5, cpp_type=1, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='numInPlasma', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='num_local_objects', full_name='ray.rpc.CoreWorkerStats.num_local_objects', index=10,
number=12, type=5, cpp_type=1, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='numLocalObjects', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='used_object_store_memory', full_name='ray.rpc.CoreWorkerStats.used_object_store_memory', index=11,
number=13, type=3, cpp_type=2, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='usedObjectStoreMemory', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='task_queue_length', full_name='ray.rpc.CoreWorkerStats.task_queue_length', index=12,
number=14, type=5, cpp_type=1, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='taskQueueLength', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='num_executed_tasks', full_name='ray.rpc.CoreWorkerStats.num_executed_tasks', index=13,
number=15, type=5, cpp_type=1, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='numExecutedTasks', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='actor_title', full_name='ray.rpc.CoreWorkerStats.actor_title', index=14,
number=16, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='actorTitle', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='object_refs', full_name='ray.rpc.CoreWorkerStats.object_refs', index=15,
number=17, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='objectRefs', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[_COREWORKERSTATS_USEDRESOURCESENTRY, _COREWORKERSTATS_WEBUIDISPLAYENTRY, ],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=4599,
serialized_end=5534,
)
_METRICPOINT_TAGSENTRY = _descriptor.Descriptor(
name='TagsEntry',
full_name='ray.rpc.MetricPoint.TagsEntry',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='key', full_name='ray.rpc.MetricPoint.TagsEntry.key', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='key', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='value', full_name='ray.rpc.MetricPoint.TagsEntry.value', index=1,
number=2, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='value', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=_b('8\001'),
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=5745,
serialized_end=5800,
)
_METRICPOINT = _descriptor.Descriptor(
name='MetricPoint',
full_name='ray.rpc.MetricPoint',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='metric_name', full_name='ray.rpc.MetricPoint.metric_name', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='metricName', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='timestamp', full_name='ray.rpc.MetricPoint.timestamp', index=1,
number=2, type=3, cpp_type=2, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='timestamp', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='value', full_name='ray.rpc.MetricPoint.value', index=2,
number=3, type=1, cpp_type=5, label=1,
has_default_value=False, default_value=float(0),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='value', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='tags', full_name='ray.rpc.MetricPoint.tags', index=3,
number=4, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='tags', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='description', full_name='ray.rpc.MetricPoint.description', index=4,
number=5, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='description', file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='units', full_name='ray.rpc.MetricPoint.units', index=5,
number=6, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, json_name='units', file=DESCRIPTOR),
],
extensions=[
],
nested_types=[_METRICPOINT_TAGSENTRY, ],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=5537,
serialized_end=5800,
)
_FUNCTIONDESCRIPTOR.fields_by_name['java_function_descriptor'].message_type = _JAVAFUNCTIONDESCRIPTOR
_FUNCTIONDESCRIPTOR.fields_by_name['python_function_descriptor'].message_type = _PYTHONFUNCTIONDESCRIPTOR
_FUNCTIONDESCRIPTOR.fields_by_name['cpp_function_descriptor'].message_type = _CPPFUNCTIONDESCRIPTOR
_FUNCTIONDESCRIPTOR.oneofs_by_name['function_descriptor'].fields.append(
_FUNCTIONDESCRIPTOR.fields_by_name['java_function_descriptor'])
_FUNCTIONDESCRIPTOR.fields_by_name['java_function_descriptor'].containing_oneof = _FUNCTIONDESCRIPTOR.oneofs_by_name['function_descriptor']
_FUNCTIONDESCRIPTOR.oneofs_by_name['function_descriptor'].fields.append(
_FUNCTIONDESCRIPTOR.fields_by_name['python_function_descriptor'])
_FUNCTIONDESCRIPTOR.fields_by_name['python_function_descriptor'].containing_oneof = _FUNCTIONDESCRIPTOR.oneofs_by_name['function_descriptor']
_FUNCTIONDESCRIPTOR.oneofs_by_name['function_descriptor'].fields.append(
_FUNCTIONDESCRIPTOR.fields_by_name['cpp_function_descriptor'])
_FUNCTIONDESCRIPTOR.fields_by_name['cpp_function_descriptor'].containing_oneof = _FUNCTIONDESCRIPTOR.oneofs_by_name['function_descriptor']
_TASKSPEC_REQUIREDRESOURCESENTRY.containing_type = _TASKSPEC
_TASKSPEC_REQUIREDPLACEMENTRESOURCESENTRY.containing_type = _TASKSPEC
_TASKSPEC.fields_by_name['type'].enum_type = _TASKTYPE
_TASKSPEC.fields_by_name['language'].enum_type = _LANGUAGE
_TASKSPEC.fields_by_name['function_descriptor'].message_type = _FUNCTIONDESCRIPTOR
_TASKSPEC.fields_by_name['caller_address'].message_type = _ADDRESS
_TASKSPEC.fields_by_name['args'].message_type = _TASKARG
_TASKSPEC.fields_by_name['required_resources'].message_type = _TASKSPEC_REQUIREDRESOURCESENTRY
_TASKSPEC.fields_by_name['required_placement_resources'].message_type = _TASKSPEC_REQUIREDPLACEMENTRESOURCESENTRY
_TASKSPEC.fields_by_name['actor_creation_task_spec'].message_type = _ACTORCREATIONTASKSPEC
_TASKSPEC.fields_by_name['actor_task_spec'].message_type = _ACTORTASKSPEC
_BUNDLE_BUNDLEIDENTIFIER.containing_type = _BUNDLE
_BUNDLE_UNITRESOURCESENTRY.containing_type = _BUNDLE
_BUNDLE.fields_by_name['bundle_id'].message_type = _BUNDLE_BUNDLEIDENTIFIER
_BUNDLE.fields_by_name['unit_resources'].message_type = _BUNDLE_UNITRESOURCESENTRY
_PLACEMENTGROUPSPEC.fields_by_name['bundles'].message_type = _BUNDLE
_PLACEMENTGROUPSPEC.fields_by_name['strategy'].enum_type = _PLACEMENTSTRATEGY
_OBJECTREFERENCE.fields_by_name['owner_address'].message_type = _ADDRESS
_TASKARG.fields_by_name['object_ref'].message_type = _OBJECTREFERENCE
_TASK.fields_by_name['task_spec'].message_type = _TASKSPEC
_TASK.fields_by_name['task_execution_spec'].message_type = _TASKEXECUTIONSPEC
_RESOURCEMAPENTRY.fields_by_name['resource_ids'].message_type = _RESOURCEID
_VIEWDATA_MEASURE.containing_type = _VIEWDATA
_VIEWDATA.fields_by_name['measures'].message_type = _VIEWDATA_MEASURE
_RESOURCEALLOCATIONS_RESOURCESLOT.containing_type = _RESOURCEALLOCATIONS
_RESOURCEALLOCATIONS.fields_by_name['resource_slots'].message_type = _RESOURCEALLOCATIONS_RESOURCESLOT
_COREWORKERSTATS_USEDRESOURCESENTRY.fields_by_name['value'].message_type = _RESOURCEALLOCATIONS
_COREWORKERSTATS_USEDRESOURCESENTRY.containing_type = _COREWORKERSTATS
_COREWORKERSTATS_WEBUIDISPLAYENTRY.containing_type = _COREWORKERSTATS
_COREWORKERSTATS.fields_by_name['used_resources'].message_type = _COREWORKERSTATS_USEDRESOURCESENTRY
_COREWORKERSTATS.fields_by_name['webui_display'].message_type = _COREWORKERSTATS_WEBUIDISPLAYENTRY
_COREWORKERSTATS.fields_by_name['object_refs'].message_type = _OBJECTREFINFO
_METRICPOINT_TAGSENTRY.containing_type = _METRICPOINT
_METRICPOINT.fields_by_name['tags'].message_type = _METRICPOINT_TAGSENTRY
DESCRIPTOR.message_types_by_name['Address'] = _ADDRESS
DESCRIPTOR.message_types_by_name['JavaFunctionDescriptor'] = _JAVAFUNCTIONDESCRIPTOR
DESCRIPTOR.message_types_by_name['PythonFunctionDescriptor'] = _PYTHONFUNCTIONDESCRIPTOR
DESCRIPTOR.message_types_by_name['CppFunctionDescriptor'] = _CPPFUNCTIONDESCRIPTOR
DESCRIPTOR.message_types_by_name['FunctionDescriptor'] = _FUNCTIONDESCRIPTOR
DESCRIPTOR.message_types_by_name['TaskSpec'] = _TASKSPEC
DESCRIPTOR.message_types_by_name['Bundle'] = _BUNDLE
DESCRIPTOR.message_types_by_name['PlacementGroupSpec'] = _PLACEMENTGROUPSPEC
DESCRIPTOR.message_types_by_name['ObjectReference'] = _OBJECTREFERENCE
DESCRIPTOR.message_types_by_name['TaskArg'] = _TASKARG
DESCRIPTOR.message_types_by_name['ActorCreationTaskSpec'] = _ACTORCREATIONTASKSPEC
DESCRIPTOR.message_types_by_name['ActorTaskSpec'] = _ACTORTASKSPEC
DESCRIPTOR.message_types_by_name['TaskExecutionSpec'] = _TASKEXECUTIONSPEC
DESCRIPTOR.message_types_by_name['Task'] = _TASK
DESCRIPTOR.message_types_by_name['ResourceId'] = _RESOURCEID
DESCRIPTOR.message_types_by_name['ResourceMapEntry'] = _RESOURCEMAPENTRY
DESCRIPTOR.message_types_by_name['ViewData'] = _VIEWDATA
DESCRIPTOR.message_types_by_name['ObjectRefInfo'] = _OBJECTREFINFO
DESCRIPTOR.message_types_by_name['ResourceAllocations'] = _RESOURCEALLOCATIONS
DESCRIPTOR.message_types_by_name['CoreWorkerStats'] = _COREWORKERSTATS
DESCRIPTOR.message_types_by_name['MetricPoint'] = _METRICPOINT
DESCRIPTOR.enum_types_by_name['Language'] = _LANGUAGE
DESCRIPTOR.enum_types_by_name['WorkerType'] = _WORKERTYPE
DESCRIPTOR.enum_types_by_name['TaskType'] = _TASKTYPE
DESCRIPTOR.enum_types_by_name['PlacementStrategy'] = _PLACEMENTSTRATEGY
_sym_db.RegisterFileDescriptor(DESCRIPTOR)
Address = _reflection.GeneratedProtocolMessageType('Address', (_message.Message,), {
'DESCRIPTOR' : _ADDRESS,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.Address)
})
_sym_db.RegisterMessage(Address)
JavaFunctionDescriptor = _reflection.GeneratedProtocolMessageType('JavaFunctionDescriptor', (_message.Message,), {
'DESCRIPTOR' : _JAVAFUNCTIONDESCRIPTOR,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.JavaFunctionDescriptor)
})
_sym_db.RegisterMessage(JavaFunctionDescriptor)
PythonFunctionDescriptor = _reflection.GeneratedProtocolMessageType('PythonFunctionDescriptor', (_message.Message,), {
'DESCRIPTOR' : _PYTHONFUNCTIONDESCRIPTOR,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.PythonFunctionDescriptor)
})
_sym_db.RegisterMessage(PythonFunctionDescriptor)
CppFunctionDescriptor = _reflection.GeneratedProtocolMessageType('CppFunctionDescriptor', (_message.Message,), {
'DESCRIPTOR' : _CPPFUNCTIONDESCRIPTOR,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.CppFunctionDescriptor)
})
_sym_db.RegisterMessage(CppFunctionDescriptor)
FunctionDescriptor = _reflection.GeneratedProtocolMessageType('FunctionDescriptor', (_message.Message,), {
'DESCRIPTOR' : _FUNCTIONDESCRIPTOR,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.FunctionDescriptor)
})
_sym_db.RegisterMessage(FunctionDescriptor)
TaskSpec = _reflection.GeneratedProtocolMessageType('TaskSpec', (_message.Message,), {
'RequiredResourcesEntry' : _reflection.GeneratedProtocolMessageType('RequiredResourcesEntry', (_message.Message,), {
'DESCRIPTOR' : _TASKSPEC_REQUIREDRESOURCESENTRY,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.TaskSpec.RequiredResourcesEntry)
})
,
'RequiredPlacementResourcesEntry' : _reflection.GeneratedProtocolMessageType('RequiredPlacementResourcesEntry', (_message.Message,), {
'DESCRIPTOR' : _TASKSPEC_REQUIREDPLACEMENTRESOURCESENTRY,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.TaskSpec.RequiredPlacementResourcesEntry)
})
,
'DESCRIPTOR' : _TASKSPEC,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.TaskSpec)
})
_sym_db.RegisterMessage(TaskSpec)
_sym_db.RegisterMessage(TaskSpec.RequiredResourcesEntry)
_sym_db.RegisterMessage(TaskSpec.RequiredPlacementResourcesEntry)
Bundle = _reflection.GeneratedProtocolMessageType('Bundle', (_message.Message,), {
'BundleIdentifier' : _reflection.GeneratedProtocolMessageType('BundleIdentifier', (_message.Message,), {
'DESCRIPTOR' : _BUNDLE_BUNDLEIDENTIFIER,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.Bundle.BundleIdentifier)
})
,
'UnitResourcesEntry' : _reflection.GeneratedProtocolMessageType('UnitResourcesEntry', (_message.Message,), {
'DESCRIPTOR' : _BUNDLE_UNITRESOURCESENTRY,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.Bundle.UnitResourcesEntry)
})
,
'DESCRIPTOR' : _BUNDLE,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.Bundle)
})
_sym_db.RegisterMessage(Bundle)
_sym_db.RegisterMessage(Bundle.BundleIdentifier)
_sym_db.RegisterMessage(Bundle.UnitResourcesEntry)
PlacementGroupSpec = _reflection.GeneratedProtocolMessageType('PlacementGroupSpec', (_message.Message,), {
'DESCRIPTOR' : _PLACEMENTGROUPSPEC,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.PlacementGroupSpec)
})
_sym_db.RegisterMessage(PlacementGroupSpec)
ObjectReference = _reflection.GeneratedProtocolMessageType('ObjectReference', (_message.Message,), {
'DESCRIPTOR' : _OBJECTREFERENCE,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.ObjectReference)
})
_sym_db.RegisterMessage(ObjectReference)
TaskArg = _reflection.GeneratedProtocolMessageType('TaskArg', (_message.Message,), {
'DESCRIPTOR' : _TASKARG,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.TaskArg)
})
_sym_db.RegisterMessage(TaskArg)
ActorCreationTaskSpec = _reflection.GeneratedProtocolMessageType('ActorCreationTaskSpec', (_message.Message,), {
'DESCRIPTOR' : _ACTORCREATIONTASKSPEC,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.ActorCreationTaskSpec)
})
_sym_db.RegisterMessage(ActorCreationTaskSpec)
ActorTaskSpec = _reflection.GeneratedProtocolMessageType('ActorTaskSpec', (_message.Message,), {
'DESCRIPTOR' : _ACTORTASKSPEC,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.ActorTaskSpec)
})
_sym_db.RegisterMessage(ActorTaskSpec)
TaskExecutionSpec = _reflection.GeneratedProtocolMessageType('TaskExecutionSpec', (_message.Message,), {
'DESCRIPTOR' : _TASKEXECUTIONSPEC,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.TaskExecutionSpec)
})
_sym_db.RegisterMessage(TaskExecutionSpec)
Task = _reflection.GeneratedProtocolMessageType('Task', (_message.Message,), {
'DESCRIPTOR' : _TASK,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.Task)
})
_sym_db.RegisterMessage(Task)
ResourceId = _reflection.GeneratedProtocolMessageType('ResourceId', (_message.Message,), {
'DESCRIPTOR' : _RESOURCEID,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.ResourceId)
})
_sym_db.RegisterMessage(ResourceId)
ResourceMapEntry = _reflection.GeneratedProtocolMessageType('ResourceMapEntry', (_message.Message,), {
'DESCRIPTOR' : _RESOURCEMAPENTRY,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.ResourceMapEntry)
})
_sym_db.RegisterMessage(ResourceMapEntry)
ViewData = _reflection.GeneratedProtocolMessageType('ViewData', (_message.Message,), {
'Measure' : _reflection.GeneratedProtocolMessageType('Measure', (_message.Message,), {
'DESCRIPTOR' : _VIEWDATA_MEASURE,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.ViewData.Measure)
})
,
'DESCRIPTOR' : _VIEWDATA,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.ViewData)
})
_sym_db.RegisterMessage(ViewData)
_sym_db.RegisterMessage(ViewData.Measure)
ObjectRefInfo = _reflection.GeneratedProtocolMessageType('ObjectRefInfo', (_message.Message,), {
'DESCRIPTOR' : _OBJECTREFINFO,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.ObjectRefInfo)
})
_sym_db.RegisterMessage(ObjectRefInfo)
ResourceAllocations = _reflection.GeneratedProtocolMessageType('ResourceAllocations', (_message.Message,), {
'ResourceSlot' : _reflection.GeneratedProtocolMessageType('ResourceSlot', (_message.Message,), {
'DESCRIPTOR' : _RESOURCEALLOCATIONS_RESOURCESLOT,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.ResourceAllocations.ResourceSlot)
})
,
'DESCRIPTOR' : _RESOURCEALLOCATIONS,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.ResourceAllocations)
})
_sym_db.RegisterMessage(ResourceAllocations)
_sym_db.RegisterMessage(ResourceAllocations.ResourceSlot)
CoreWorkerStats = _reflection.GeneratedProtocolMessageType('CoreWorkerStats', (_message.Message,), {
'UsedResourcesEntry' : _reflection.GeneratedProtocolMessageType('UsedResourcesEntry', (_message.Message,), {
'DESCRIPTOR' : _COREWORKERSTATS_USEDRESOURCESENTRY,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.CoreWorkerStats.UsedResourcesEntry)
})
,
'WebuiDisplayEntry' : _reflection.GeneratedProtocolMessageType('WebuiDisplayEntry', (_message.Message,), {
'DESCRIPTOR' : _COREWORKERSTATS_WEBUIDISPLAYENTRY,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.CoreWorkerStats.WebuiDisplayEntry)
})
,
'DESCRIPTOR' : _COREWORKERSTATS,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.CoreWorkerStats)
})
_sym_db.RegisterMessage(CoreWorkerStats)
_sym_db.RegisterMessage(CoreWorkerStats.UsedResourcesEntry)
_sym_db.RegisterMessage(CoreWorkerStats.WebuiDisplayEntry)
MetricPoint = _reflection.GeneratedProtocolMessageType('MetricPoint', (_message.Message,), {
'TagsEntry' : _reflection.GeneratedProtocolMessageType('TagsEntry', (_message.Message,), {
'DESCRIPTOR' : _METRICPOINT_TAGSENTRY,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.MetricPoint.TagsEntry)
})
,
'DESCRIPTOR' : _METRICPOINT,
'__module__' : 'src.ray.protobuf.common_pb2'
# @@protoc_insertion_point(class_scope:ray.rpc.MetricPoint)
})
_sym_db.RegisterMessage(MetricPoint)
_sym_db.RegisterMessage(MetricPoint.TagsEntry)
DESCRIPTOR._options = None
_TASKSPEC_REQUIREDRESOURCESENTRY._options = None
_TASKSPEC_REQUIREDPLACEMENTRESOURCESENTRY._options = None
_BUNDLE_UNITRESOURCESENTRY._options = None
_COREWORKERSTATS_USEDRESOURCESENTRY._options = None
_COREWORKERSTATS_WEBUIDISPLAYENTRY._options = None
_METRICPOINT_TAGSENTRY._options = None
# @@protoc_insertion_point(module_scope)
Raw
common_pb2.pyi
# @generated by mypy-protobuf. Do not edit manually!
import sys
from google.protobuf.descriptor import (
Descriptor as google___protobuf___descriptor___Descriptor,
EnumDescriptor as google___protobuf___descriptor___EnumDescriptor,
FileDescriptor as google___protobuf___descriptor___FileDescriptor,
)
from google.protobuf.internal.containers import (
RepeatedCompositeFieldContainer as google___protobuf___internal___containers___RepeatedCompositeFieldContainer,
RepeatedScalarFieldContainer as google___protobuf___internal___containers___RepeatedScalarFieldContainer,
)
from google.protobuf.internal.enum_type_wrapper import (
_EnumTypeWrapper as google___protobuf___internal___enum_type_wrapper____EnumTypeWrapper,
)
from google.protobuf.message import (
Message as google___protobuf___message___Message,
)
from typing import (
Iterable as typing___Iterable,
Mapping as typing___Mapping,
MutableMapping as typing___MutableMapping,
NewType as typing___NewType,
Optional as typing___Optional,
Text as typing___Text,
cast as typing___cast,
)
from typing_extensions import (
Literal as typing_extensions___Literal,
)
builtin___bool = bool
builtin___bytes = bytes
builtin___float = float
builtin___int = int
DESCRIPTOR: google___protobuf___descriptor___FileDescriptor = ...
LanguageValue = typing___NewType('LanguageValue', builtin___int)
type___LanguageValue = LanguageValue
Language: _Language
class _Language(google___protobuf___internal___enum_type_wrapper____EnumTypeWrapper[LanguageValue]):
DESCRIPTOR: google___protobuf___descriptor___EnumDescriptor = ...
PYTHON = typing___cast(LanguageValue, 0)
JAVA = typing___cast(LanguageValue, 1)
CPP = typing___cast(LanguageValue, 2)
PYTHON = typing___cast(LanguageValue, 0)
JAVA = typing___cast(LanguageValue, 1)
CPP = typing___cast(LanguageValue, 2)
type___Language = Language
WorkerTypeValue = typing___NewType('WorkerTypeValue', builtin___int)
type___WorkerTypeValue = WorkerTypeValue
WorkerType: _WorkerType
class _WorkerType(google___protobuf___internal___enum_type_wrapper____EnumTypeWrapper[WorkerTypeValue]):
DESCRIPTOR: google___protobuf___descriptor___EnumDescriptor = ...
WORKER = typing___cast(WorkerTypeValue, 0)
DRIVER = typing___cast(WorkerTypeValue, 1)
WORKER = typing___cast(WorkerTypeValue, 0)
DRIVER = typing___cast(WorkerTypeValue, 1)
type___WorkerType = WorkerType
TaskTypeValue = typing___NewType('TaskTypeValue', builtin___int)
type___TaskTypeValue = TaskTypeValue
TaskType: _TaskType
class _TaskType(google___protobuf___internal___enum_type_wrapper____EnumTypeWrapper[TaskTypeValue]):
DESCRIPTOR: google___protobuf___descriptor___EnumDescriptor = ...
NORMAL_TASK = typing___cast(TaskTypeValue, 0)
ACTOR_CREATION_TASK = typing___cast(TaskTypeValue, 1)
ACTOR_TASK = typing___cast(TaskTypeValue, 2)
DRIVER_TASK = typing___cast(TaskTypeValue, 3)
NORMAL_TASK = typing___cast(TaskTypeValue, 0)
ACTOR_CREATION_TASK = typing___cast(TaskTypeValue, 1)
ACTOR_TASK = typing___cast(TaskTypeValue, 2)
DRIVER_TASK = typing___cast(TaskTypeValue, 3)
type___TaskType = TaskType
PlacementStrategyValue = typing___NewType('PlacementStrategyValue', builtin___int)
type___PlacementStrategyValue = PlacementStrategyValue
PlacementStrategy: _PlacementStrategy
class _PlacementStrategy(google___protobuf___internal___enum_type_wrapper____EnumTypeWrapper[PlacementStrategyValue]):
DESCRIPTOR: google___protobuf___descriptor___EnumDescriptor = ...
PACK = typing___cast(PlacementStrategyValue, 0)
SPREAD = typing___cast(PlacementStrategyValue, 1)
PACK = typing___cast(PlacementStrategyValue, 0)
SPREAD = typing___cast(PlacementStrategyValue, 1)
type___PlacementStrategy = PlacementStrategy
class Address(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
raylet_id: builtin___bytes = ...
ip_address: typing___Text = ...
port: builtin___int = ...
worker_id: builtin___bytes = ...
def __init__(self,
*,
raylet_id : typing___Optional[builtin___bytes] = None,
ip_address : typing___Optional[typing___Text] = None,
port : typing___Optional[builtin___int] = None,
worker_id : typing___Optional[builtin___bytes] = None,
) -> None: ...
def ClearField(self, field_name: typing_extensions___Literal[u"ip_address",b"ip_address",u"port",b"port",u"raylet_id",b"raylet_id",u"worker_id",b"worker_id"]) -> None: ...
type___Address = Address
class JavaFunctionDescriptor(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
class_name: typing___Text = ...
function_name: typing___Text = ...
signature: typing___Text = ...
def __init__(self,
*,
class_name : typing___Optional[typing___Text] = None,
function_name : typing___Optional[typing___Text] = None,
signature : typing___Optional[typing___Text] = None,
) -> None: ...
def ClearField(self, field_name: typing_extensions___Literal[u"class_name",b"class_name",u"function_name",b"function_name",u"signature",b"signature"]) -> None: ...
type___JavaFunctionDescriptor = JavaFunctionDescriptor
class PythonFunctionDescriptor(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
module_name: typing___Text = ...
class_name: typing___Text = ...
function_name: typing___Text = ...
function_hash: typing___Text = ...
def __init__(self,
*,
module_name : typing___Optional[typing___Text] = None,
class_name : typing___Optional[typing___Text] = None,
function_name : typing___Optional[typing___Text] = None,
function_hash : typing___Optional[typing___Text] = None,
) -> None: ...
def ClearField(self, field_name: typing_extensions___Literal[u"class_name",b"class_name",u"function_hash",b"function_hash",u"function_name",b"function_name",u"module_name",b"module_name"]) -> None: ...
type___PythonFunctionDescriptor = PythonFunctionDescriptor
class CppFunctionDescriptor(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
lib_name: typing___Text = ...
function_offset: typing___Text = ...
exec_function_offset: typing___Text = ...
def __init__(self,
*,
lib_name : typing___Optional[typing___Text] = None,
function_offset : typing___Optional[typing___Text] = None,
exec_function_offset : typing___Optional[typing___Text] = None,
) -> None: ...
def ClearField(self, field_name: typing_extensions___Literal[u"exec_function_offset",b"exec_function_offset",u"function_offset",b"function_offset",u"lib_name",b"lib_name"]) -> None: ...
type___CppFunctionDescriptor = CppFunctionDescriptor
class FunctionDescriptor(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
@property
def java_function_descriptor(self) -> type___JavaFunctionDescriptor: ...
@property
def python_function_descriptor(self) -> type___PythonFunctionDescriptor: ...
@property
def cpp_function_descriptor(self) -> type___CppFunctionDescriptor: ...
def __init__(self,
*,
java_function_descriptor : typing___Optional[type___JavaFunctionDescriptor] = None,
python_function_descriptor : typing___Optional[type___PythonFunctionDescriptor] = None,
cpp_function_descriptor : typing___Optional[type___CppFunctionDescriptor] = None,
) -> None: ...
def HasField(self, field_name: typing_extensions___Literal[u"cpp_function_descriptor",b"cpp_function_descriptor",u"function_descriptor",b"function_descriptor",u"java_function_descriptor",b"java_function_descriptor",u"python_function_descriptor",b"python_function_descriptor"]) -> builtin___bool: ...
def ClearField(self, field_name: typing_extensions___Literal[u"cpp_function_descriptor",b"cpp_function_descriptor",u"function_descriptor",b"function_descriptor",u"java_function_descriptor",b"java_function_descriptor",u"python_function_descriptor",b"python_function_descriptor"]) -> None: ...
def WhichOneof(self, oneof_group: typing_extensions___Literal[u"function_descriptor",b"function_descriptor"]) -> typing_extensions___Literal["java_function_descriptor","python_function_descriptor","cpp_function_descriptor"]: ...
type___FunctionDescriptor = FunctionDescriptor
class TaskSpec(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
class RequiredResourcesEntry(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
key: typing___Text = ...
value: builtin___float = ...
def __init__(self,
*,
key : typing___Optional[typing___Text] = None,
value : typing___Optional[builtin___float] = None,
) -> None: ...
def ClearField(self, field_name: typing_extensions___Literal[u"key",b"key",u"value",b"value"]) -> None: ...
type___RequiredResourcesEntry = RequiredResourcesEntry
class RequiredPlacementResourcesEntry(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
key: typing___Text = ...
value: builtin___float = ...
def __init__(self,
*,
key : typing___Optional[typing___Text] = None,
value : typing___Optional[builtin___float] = None,
) -> None: ...
def ClearField(self, field_name: typing_extensions___Literal[u"key",b"key",u"value",b"value"]) -> None: ...
type___RequiredPlacementResourcesEntry = RequiredPlacementResourcesEntry
type: type___TaskTypeValue = ...
language: type___LanguageValue = ...
job_id: builtin___bytes = ...
task_id: builtin___bytes = ...
parent_task_id: builtin___bytes = ...
parent_counter: builtin___int = ...
caller_id: builtin___bytes = ...
num_returns: builtin___int = ...
max_retries: builtin___int = ...
@property
def function_descriptor(self) -> type___FunctionDescriptor: ...
@property
def caller_address(self) -> type___Address: ...
@property
def args(self) -> google___protobuf___internal___containers___RepeatedCompositeFieldContainer[type___TaskArg]: ...
@property
def required_resources(self) -> typing___MutableMapping[typing___Text, builtin___float]: ...
@property
def required_placement_resources(self) -> typing___MutableMapping[typing___Text, builtin___float]: ...
@property
def actor_creation_task_spec(self) -> type___ActorCreationTaskSpec: ...
@property
def actor_task_spec(self) -> type___ActorTaskSpec: ...
def __init__(self,
*,
type : typing___Optional[type___TaskTypeValue] = None,
language : typing___Optional[type___LanguageValue] = None,
function_descriptor : typing___Optional[type___FunctionDescriptor] = None,
job_id : typing___Optional[builtin___bytes] = None,
task_id : typing___Optional[builtin___bytes] = None,
parent_task_id : typing___Optional[builtin___bytes] = None,
parent_counter : typing___Optional[builtin___int] = None,
caller_id : typing___Optional[builtin___bytes] = None,
caller_address : typing___Optional[type___Address] = None,
args : typing___Optional[typing___Iterable[type___TaskArg]] = None,
num_returns : typing___Optional[builtin___int] = None,
required_resources : typing___Optional[typing___Mapping[typing___Text, builtin___float]] = None,
required_placement_resources : typing___Optional[typing___Mapping[typing___Text, builtin___float]] = None,
actor_creation_task_spec : typing___Optional[type___ActorCreationTaskSpec] = None,
actor_task_spec : typing___Optional[type___ActorTaskSpec] = None,
max_retries : typing___Optional[builtin___int] = None,
) -> None: ...
def HasField(self, field_name: typing_extensions___Literal[u"actor_creation_task_spec",b"actor_creation_task_spec",u"actor_task_spec",b"actor_task_spec",u"caller_address",b"caller_address",u"function_descriptor",b"function_descriptor"]) -> builtin___bool: ...
def ClearField(self, field_name: typing_extensions___Literal[u"actor_creation_task_spec",b"actor_creation_task_spec",u"actor_task_spec",b"actor_task_spec",u"args",b"args",u"caller_address",b"caller_address",u"caller_id",b"caller_id",u"function_descriptor",b"function_descriptor",u"job_id",b"job_id",u"language",b"language",u"max_retries",b"max_retries",u"num_returns",b"num_returns",u"parent_counter",b"parent_counter",u"parent_task_id",b"parent_task_id",u"required_placement_resources",b"required_placement_resources",u"required_resources",b"required_resources",u"task_id",b"task_id",u"type",b"type"]) -> None: ...
type___TaskSpec = TaskSpec
class Bundle(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
class BundleIdentifier(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
placement_group_id: builtin___bytes = ...
bundle_index: builtin___int = ...
def __init__(self,
*,
placement_group_id : typing___Optional[builtin___bytes] = None,
bundle_index : typing___Optional[builtin___int] = None,
) -> None: ...
def ClearField(self, field_name: typing_extensions___Literal[u"bundle_index",b"bundle_index",u"placement_group_id",b"placement_group_id"]) -> None: ...
type___BundleIdentifier = BundleIdentifier
class UnitResourcesEntry(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
key: typing___Text = ...
value: builtin___float = ...
def __init__(self,
*,
key : typing___Optional[typing___Text] = None,
value : typing___Optional[builtin___float] = None,
) -> None: ...
def ClearField(self, field_name: typing_extensions___Literal[u"key",b"key",u"value",b"value"]) -> None: ...
type___UnitResourcesEntry = UnitResourcesEntry
@property
def bundle_id(self) -> type___Bundle.BundleIdentifier: ...
@property
def unit_resources(self) -> typing___MutableMapping[typing___Text, builtin___float]: ...
def __init__(self,
*,
bundle_id : typing___Optional[type___Bundle.BundleIdentifier] = None,
unit_resources : typing___Optional[typing___Mapping[typing___Text, builtin___float]] = None,
) -> None: ...
def HasField(self, field_name: typing_extensions___Literal[u"bundle_id",b"bundle_id"]) -> builtin___bool: ...
def ClearField(self, field_name: typing_extensions___Literal[u"bundle_id",b"bundle_id",u"unit_resources",b"unit_resources"]) -> None: ...
type___Bundle = Bundle
class PlacementGroupSpec(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
placement_group_id: builtin___bytes = ...
name: typing___Text = ...
strategy: type___PlacementStrategyValue = ...
@property
def bundles(self) -> google___protobuf___internal___containers___RepeatedCompositeFieldContainer[type___Bundle]: ...
def __init__(self,
*,
placement_group_id : typing___Optional[builtin___bytes] = None,
name : typing___Optional[typing___Text] = None,
bundles : typing___Optional[typing___Iterable[type___Bundle]] = None,
strategy : typing___Optional[type___PlacementStrategyValue] = None,
) -> None: ...
def ClearField(self, field_name: typing_extensions___Literal[u"bundles",b"bundles",u"name",b"name",u"placement_group_id",b"placement_group_id",u"strategy",b"strategy"]) -> None: ...
type___PlacementGroupSpec = PlacementGroupSpec
class ObjectReference(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
object_id: builtin___bytes = ...
@property
def owner_address(self) -> type___Address: ...
def __init__(self,
*,
object_id : typing___Optional[builtin___bytes] = None,
owner_address : typing___Optional[type___Address] = None,
) -> None: ...
def HasField(self, field_name: typing_extensions___Literal[u"owner_address",b"owner_address"]) -> builtin___bool: ...
def ClearField(self, field_name: typing_extensions___Literal[u"object_id",b"object_id",u"owner_address",b"owner_address"]) -> None: ...
type___ObjectReference = ObjectReference
class TaskArg(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
data: builtin___bytes = ...
metadata: builtin___bytes = ...
nested_inlined_ids: google___protobuf___internal___containers___RepeatedScalarFieldContainer[builtin___bytes] = ...
@property
def object_ref(self) -> type___ObjectReference: ...
def __init__(self,
*,
object_ref : typing___Optional[type___ObjectReference] = None,
data : typing___Optional[builtin___bytes] = None,
metadata : typing___Optional[builtin___bytes] = None,
nested_inlined_ids : typing___Optional[typing___Iterable[builtin___bytes]] = None,
) -> None: ...
def HasField(self, field_name: typing_extensions___Literal[u"object_ref",b"object_ref"]) -> builtin___bool: ...
def ClearField(self, field_name: typing_extensions___Literal[u"data",b"data",u"metadata",b"metadata",u"nested_inlined_ids",b"nested_inlined_ids",u"object_ref",b"object_ref"]) -> None: ...
type___TaskArg = TaskArg
class ActorCreationTaskSpec(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
actor_id: builtin___bytes = ...
max_actor_restarts: builtin___int = ...
dynamic_worker_options: google___protobuf___internal___containers___RepeatedScalarFieldContainer[typing___Text] = ...
max_concurrency: builtin___int = ...
is_detached: builtin___bool = ...
name: typing___Text = ...
is_asyncio: builtin___bool = ...
extension_data: typing___Text = ...
def __init__(self,
*,
actor_id : typing___Optional[builtin___bytes] = None,
max_actor_restarts : typing___Optional[builtin___int] = None,
dynamic_worker_options : typing___Optional[typing___Iterable[typing___Text]] = None,
max_concurrency : typing___Optional[builtin___int] = None,
is_detached : typing___Optional[builtin___bool] = None,
name : typing___Optional[typing___Text] = None,
is_asyncio : typing___Optional[builtin___bool] = None,
extension_data : typing___Optional[typing___Text] = None,
) -> None: ...
def ClearField(self, field_name: typing_extensions___Literal[u"actor_id",b"actor_id",u"dynamic_worker_options",b"dynamic_worker_options",u"extension_data",b"extension_data",u"is_asyncio",b"is_asyncio",u"is_detached",b"is_detached",u"max_actor_restarts",b"max_actor_restarts",u"max_concurrency",b"max_concurrency",u"name",b"name"]) -> None: ...
type___ActorCreationTaskSpec = ActorCreationTaskSpec
class ActorTaskSpec(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
actor_id: builtin___bytes = ...
actor_creation_dummy_object_id: builtin___bytes = ...
actor_counter: builtin___int = ...
previous_actor_task_dummy_object_id: builtin___bytes = ...
def __init__(self,
*,
actor_id : typing___Optional[builtin___bytes] = None,
actor_creation_dummy_object_id : typing___Optional[builtin___bytes] = None,
actor_counter : typing___Optional[builtin___int] = None,
previous_actor_task_dummy_object_id : typing___Optional[builtin___bytes] = None,
) -> None: ...
def ClearField(self, field_name: typing_extensions___Literal[u"actor_counter",b"actor_counter",u"actor_creation_dummy_object_id",b"actor_creation_dummy_object_id",u"actor_id",b"actor_id",u"previous_actor_task_dummy_object_id",b"previous_actor_task_dummy_object_id"]) -> None: ...
type___ActorTaskSpec = ActorTaskSpec
class TaskExecutionSpec(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
last_timestamp: builtin___float = ...
num_forwards: builtin___int = ...
def __init__(self,
*,
last_timestamp : typing___Optional[builtin___float] = None,
num_forwards : typing___Optional[builtin___int] = None,
) -> None: ...
def ClearField(self, field_name: typing_extensions___Literal[u"last_timestamp",b"last_timestamp",u"num_forwards",b"num_forwards"]) -> None: ...
type___TaskExecutionSpec = TaskExecutionSpec
class Task(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
@property
def task_spec(self) -> type___TaskSpec: ...
@property
def task_execution_spec(self) -> type___TaskExecutionSpec: ...
def __init__(self,
*,
task_spec : typing___Optional[type___TaskSpec] = None,
task_execution_spec : typing___Optional[type___TaskExecutionSpec] = None,
) -> None: ...
def HasField(self, field_name: typing_extensions___Literal[u"task_execution_spec",b"task_execution_spec",u"task_spec",b"task_spec"]) -> builtin___bool: ...
def ClearField(self, field_name: typing_extensions___Literal[u"task_execution_spec",b"task_execution_spec",u"task_spec",b"task_spec"]) -> None: ...
type___Task = Task
class ResourceId(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
index: builtin___int = ...
quantity: builtin___float = ...
def __init__(self,
*,
index : typing___Optional[builtin___int] = None,
quantity : typing___Optional[builtin___float] = None,
) -> None: ...
def ClearField(self, field_name: typing_extensions___Literal[u"index",b"index",u"quantity",b"quantity"]) -> None: ...
type___ResourceId = ResourceId
class ResourceMapEntry(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
name: typing___Text = ...
@property
def resource_ids(self) -> google___protobuf___internal___containers___RepeatedCompositeFieldContainer[type___ResourceId]: ...
def __init__(self,
*,
name : typing___Optional[typing___Text] = None,
resource_ids : typing___Optional[typing___Iterable[type___ResourceId]] = None,
) -> None: ...
def ClearField(self, field_name: typing_extensions___Literal[u"name",b"name",u"resource_ids",b"resource_ids"]) -> None: ...
type___ResourceMapEntry = ResourceMapEntry
class ViewData(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
class Measure(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
tags: typing___Text = ...
int_value: builtin___int = ...
double_value: builtin___float = ...
distribution_min: builtin___float = ...
distribution_mean: builtin___float = ...
distribution_max: builtin___float = ...
distribution_count: builtin___float = ...
distribution_bucket_boundaries: google___protobuf___internal___containers___RepeatedScalarFieldContainer[builtin___float] = ...
distribution_bucket_counts: google___protobuf___internal___containers___RepeatedScalarFieldContainer[builtin___float] = ...
def __init__(self,
*,
tags : typing___Optional[typing___Text] = None,
int_value : typing___Optional[builtin___int] = None,
double_value : typing___Optional[builtin___float] = None,
distribution_min : typing___Optional[builtin___float] = None,
distribution_mean : typing___Optional[builtin___float] = None,
distribution_max : typing___Optional[builtin___float] = None,
distribution_count : typing___Optional[builtin___float] = None,
distribution_bucket_boundaries : typing___Optional[typing___Iterable[builtin___float]] = None,
distribution_bucket_counts : typing___Optional[typing___Iterable[builtin___float]] = None,
) -> None: ...
def ClearField(self, field_name: typing_extensions___Literal[u"distribution_bucket_boundaries",b"distribution_bucket_boundaries",u"distribution_bucket_counts",b"distribution_bucket_counts",u"distribution_count",b"distribution_count",u"distribution_max",b"distribution_max",u"distribution_mean",b"distribution_mean",u"distribution_min",b"distribution_min",u"double_value",b"double_value",u"int_value",b"int_value",u"tags",b"tags"]) -> None: ...
type___Measure = Measure
view_name: typing___Text = ...
@property
def measures(self) -> google___protobuf___internal___containers___RepeatedCompositeFieldContainer[type___ViewData.Measure]: ...
def __init__(self,
*,
view_name : typing___Optional[typing___Text] = None,
measures : typing___Optional[typing___Iterable[type___ViewData.Measure]] = None,
) -> None: ...
def ClearField(self, field_name: typing_extensions___Literal[u"measures",b"measures",u"view_name",b"view_name"]) -> None: ...
type___ViewData = ViewData
class ObjectRefInfo(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
object_id: builtin___bytes = ...
call_site: typing___Text = ...
object_size: builtin___int = ...
local_ref_count: builtin___int = ...
submitted_task_ref_count: builtin___int = ...
contained_in_owned: google___protobuf___internal___containers___RepeatedScalarFieldContainer[builtin___bytes] = ...
pinned_in_memory: builtin___bool = ...
def __init__(self,
*,
object_id : typing___Optional[builtin___bytes] = None,
call_site : typing___Optional[typing___Text] = None,
object_size : typing___Optional[builtin___int] = None,
local_ref_count : typing___Optional[builtin___int] = None,
submitted_task_ref_count : typing___Optional[builtin___int] = None,
contained_in_owned : typing___Optional[typing___Iterable[builtin___bytes]] = None,
pinned_in_memory : typing___Optional[builtin___bool] = None,
) -> None: ...
def ClearField(self, field_name: typing_extensions___Literal[u"call_site",b"call_site",u"contained_in_owned",b"contained_in_owned",u"local_ref_count",b"local_ref_count",u"object_id",b"object_id",u"object_size",b"object_size",u"pinned_in_memory",b"pinned_in_memory",u"submitted_task_ref_count",b"submitted_task_ref_count"]) -> None: ...
type___ObjectRefInfo = ObjectRefInfo
class ResourceAllocations(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
class ResourceSlot(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
slot: builtin___int = ...
allocation: builtin___float = ...
def __init__(self,
*,
slot : typing___Optional[builtin___int] = None,
allocation : typing___Optional[builtin___float] = None,
) -> None: ...
def ClearField(self, field_name: typing_extensions___Literal[u"allocation",b"allocation",u"slot",b"slot"]) -> None: ...
type___ResourceSlot = ResourceSlot
@property
def resource_slots(self) -> google___protobuf___internal___containers___RepeatedCompositeFieldContainer[type___ResourceAllocations.ResourceSlot]: ...
def __init__(self,
*,
resource_slots : typing___Optional[typing___Iterable[type___ResourceAllocations.ResourceSlot]] = None,
) -> None: ...
def ClearField(self, field_name: typing_extensions___Literal[u"resource_slots",b"resource_slots"]) -> None: ...
type___ResourceAllocations = ResourceAllocations
class CoreWorkerStats(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
class UsedResourcesEntry(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
key: typing___Text = ...
@property
def value(self) -> type___ResourceAllocations: ...
def __init__(self,
*,
key : typing___Optional[typing___Text] = None,
value : typing___Optional[type___ResourceAllocations] = None,
) -> None: ...
def HasField(self, field_name: typing_extensions___Literal[u"value",b"value"]) -> builtin___bool: ...
def ClearField(self, field_name: typing_extensions___Literal[u"key",b"key",u"value",b"value"]) -> None: ...
type___UsedResourcesEntry = UsedResourcesEntry
class WebuiDisplayEntry(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
key: typing___Text = ...
value: typing___Text = ...
def __init__(self,
*,
key : typing___Optional[typing___Text] = None,
value : typing___Optional[typing___Text] = None,
) -> None: ...
def ClearField(self, field_name: typing_extensions___Literal[u"key",b"key",u"value",b"value"]) -> None: ...
type___WebuiDisplayEntry = WebuiDisplayEntry
current_task_desc: typing___Text = ...
num_pending_tasks: builtin___int = ...
num_object_refs_in_scope: builtin___int = ...
current_task_func_desc: typing___Text = ...
ip_address: typing___Text = ...
port: builtin___int = ...
actor_id: builtin___bytes = ...
num_in_plasma: builtin___int = ...
num_local_objects: builtin___int = ...
used_object_store_memory: builtin___int = ...
task_queue_length: builtin___int = ...
num_executed_tasks: builtin___int = ...
actor_title: typing___Text = ...
@property
def used_resources(self) -> typing___MutableMapping[typing___Text, type___ResourceAllocations]: ...
@property
def webui_display(self) -> typing___MutableMapping[typing___Text, typing___Text]: ...
@property
def object_refs(self) -> google___protobuf___internal___containers___RepeatedCompositeFieldContainer[type___ObjectRefInfo]: ...
def __init__(self,
*,
current_task_desc : typing___Optional[typing___Text] = None,
num_pending_tasks : typing___Optional[builtin___int] = None,
num_object_refs_in_scope : typing___Optional[builtin___int] = None,
current_task_func_desc : typing___Optional[typing___Text] = None,
ip_address : typing___Optional[typing___Text] = None,
port : typing___Optional[builtin___int] = None,
actor_id : typing___Optional[builtin___bytes] = None,
used_resources : typing___Optional[typing___Mapping[typing___Text, type___ResourceAllocations]] = None,
webui_display : typing___Optional[typing___Mapping[typing___Text, typing___Text]] = None,
num_in_plasma : typing___Optional[builtin___int] = None,
num_local_objects : typing___Optional[builtin___int] = None,
used_object_store_memory : typing___Optional[builtin___int] = None,
task_queue_length : typing___Optional[builtin___int] = None,
num_executed_tasks : typing___Optional[builtin___int] = None,
actor_title : typing___Optional[typing___Text] = None,
object_refs : typing___Optional[typing___Iterable[type___ObjectRefInfo]] = None,
) -> None: ...
def ClearField(self, field_name: typing_extensions___Literal[u"actor_id",b"actor_id",u"actor_title",b"actor_title",u"current_task_desc",b"current_task_desc",u"current_task_func_desc",b"current_task_func_desc",u"ip_address",b"ip_address",u"num_executed_tasks",b"num_executed_tasks",u"num_in_plasma",b"num_in_plasma",u"num_local_objects",b"num_local_objects",u"num_object_refs_in_scope",b"num_object_refs_in_scope",u"num_pending_tasks",b"num_pending_tasks",u"object_refs",b"object_refs",u"port",b"port",u"task_queue_length",b"task_queue_length",u"used_object_store_memory",b"used_object_store_memory",u"used_resources",b"used_resources",u"webui_display",b"webui_display"]) -> None: ...
type___CoreWorkerStats = CoreWorkerStats
class MetricPoint(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
class TagsEntry(google___protobuf___message___Message):
DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
key: typing___Text = ...
value: typing___Text = ...
def __init__(self,
*,
key : typing___Optional[typing___Text] = None,
value : typing___Optional[typing___Text] = None,
) -> None: ...
def ClearField(self, field_name: typing_extensions___Literal[u"key",b"key",u"value",b"value"]) -> None: ...
type___TagsEntry = TagsEntry
metric_name: typing___Text = ...
timestamp: builtin___int = ...
value: builtin___float = ...
description: typing___Text = ...
units: typing___Text = ...
@property
def tags(self) -> typing___MutableMapping[typing___Text, typing___Text]: ...
def __init__(self,
*,
metric_name : typing___Optional[typing___Text] = None,
timestamp : typing___Optional[builtin___int] = None,
value : typing___Optional[builtin___float] = None,
tags : typing___Optional[typing___Mapping[typing___Text, typing___Text]] = None,
description : typing___Optional[typing___Text] = None,
units : typing___Optional[typing___Text] = None,
) -> None: ...
def ClearField(self, field_name: typing_extensions___Literal[u"description",b"description",u"metric_name",b"metric_name",u"tags",b"tags",u"timestamp",b"timestamp",u"units",b"units",u"value",b"value"]) -> None: ...
type___MetricPoint = MetricPoint
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment