Gemfury

emaballarin / ray python

Repository URL to install this package:
Details
ray / core / generated / export_task_event_pb2.py
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler.  DO NOT EDIT!
# source: src/ray/protobuf/export_task_event.proto
"""Generated protocol buffer code."""
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
from google.protobuf import message as _message
from google.protobuf import reflection as _reflection
from google.protobuf import symbol_database as _symbol_database
# @@protoc_insertion_point(imports)

_sym_db = _symbol_database.Default()


from . import common_pb2 as src_dot_ray_dot_protobuf_dot_common__pb2
from . import export_runtime_env_pb2 as src_dot_ray_dot_protobuf_dot_export__runtime__env__pb2
from . import profile_events_pb2 as src_dot_ray_dot_protobuf_dot_profile__events__pb2


DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n(src/ray/protobuf/export_task_event.proto\x12\x07ray.rpc\x1a\x1dsrc/ray/protobuf/common.proto\x1a)src/ray/protobuf/export_runtime_env.proto\x1a%src/ray/protobuf/profile_events.proto\"\x8d\x12\n\x13\x45xportTaskEventData\x12\x17\n\x07task_id\x18\x01 \x01(\x0cR\x06taskId\x12%\n\x0e\x61ttempt_number\x18\x02 \x01(\x05R\rattemptNumber\x12L\n\ttask_info\x18\x03 \x01(\x0b\x32*.ray.rpc.ExportTaskEventData.TaskInfoEntryH\x00R\x08taskInfo\x88\x01\x01\x12V\n\rstate_updates\x18\x04 \x01(\x0b\x32,.ray.rpc.ExportTaskEventData.TaskStateUpdateH\x01R\x0cstateUpdates\x88\x01\x01\x12\x42\n\x0eprofile_events\x18\x05 \x01(\x0b\x32\x16.ray.rpc.ProfileEventsH\x02R\rprofileEvents\x88\x01\x01\x12\x15\n\x06job_id\x18\x06 \x01(\x0cR\x05jobId\x1a\x66\n\x0cRayErrorInfo\x12#\n\rerror_message\x18\x01 \x01(\tR\x0c\x65rrorMessage\x12\x31\n\nerror_type\x18\x02 \x01(\x0e\x32\x12.ray.rpc.ErrorTypeR\terrorType\x1a\xd1\x02\n\x0bTaskLogInfo\x12$\n\x0bstdout_file\x18\x01 \x01(\tH\x00R\nstdoutFile\x88\x01\x01\x12$\n\x0bstderr_file\x18\x02 \x01(\tH\x01R\nstderrFile\x88\x01\x01\x12&\n\x0cstdout_start\x18\x03 \x01(\x05H\x02R\x0bstdoutStart\x88\x01\x01\x12\"\n\nstdout_end\x18\x04 \x01(\x05H\x03R\tstdoutEnd\x88\x01\x01\x12&\n\x0cstderr_start\x18\x05 \x01(\x05H\x04R\x0bstderrStart\x88\x01\x01\x12\"\n\nstderr_end\x18\x06 \x01(\x05H\x05R\tstderrEnd\x88\x01\x01\x42\x0e\n\x0c_stdout_fileB\x0e\n\x0c_stderr_fileB\x0f\n\r_stdout_startB\r\n\x0b_stdout_endB\x0f\n\r_stderr_startB\r\n\x0b_stderr_end\x1a\xc6\x04\n\x0fTaskStateUpdate\x12\x1c\n\x07node_id\x18\x01 \x01(\x0cH\x00R\x06nodeId\x88\x01\x01\x12 \n\tworker_id\x18\x02 \x01(\x0cH\x01R\x08workerId\x88\x01\x01\x12M\n\nerror_info\x18\x03 \x01(\x0b\x32).ray.rpc.ExportTaskEventData.RayErrorInfoH\x02R\terrorInfo\x88\x01\x01\x12Q\n\rtask_log_info\x18\x04 \x01(\x0b\x32(.ray.rpc.ExportTaskEventData.TaskLogInfoH\x03R\x0btaskLogInfo\x88\x01\x01\x12\"\n\nworker_pid\x18\x05 \x01(\x05H\x04R\tworkerPid\x88\x01\x01\x12\x31\n\x12is_debugger_paused\x18\x06 \x01(\x08H\x05R\x10isDebuggerPaused\x88\x01\x01\x12[\n\x0bstate_ts_ns\x18\x07 \x03(\x0b\x32;.ray.rpc.ExportTaskEventData.TaskStateUpdate.StateTsNsEntryR\tstateTsNs\x1a<\n\x0eStateTsNsEntry\x12\x10\n\x03key\x18\x01 \x01(\x05R\x03key\x12\x14\n\x05value\x18\x02 \x01(\x03R\x05value:\x02\x38\x01\x42\n\n\x08_node_idB\x0c\n\n_worker_idB\r\n\x0b_error_infoB\x10\n\x0e_task_log_infoB\r\n\x0b_worker_pidB\x15\n\x13_is_debugger_paused\x1a\xfc\x06\n\rTaskInfoEntry\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\x12+\n\x12\x66unc_or_class_name\x18\x03 \x01(\tR\x0f\x66uncOrClassName\x12\x17\n\x07task_id\x18\x04 \x01(\x0cR\x06taskId\x12$\n\x0eparent_task_id\x18\x05 \x01(\x0cR\x0cparentTaskId\x12p\n\x12required_resources\x18\x06 \x03(\x0b\x32\x41.ray.rpc.ExportTaskEventData.TaskInfoEntry.RequiredResourcesEntryR\x11requiredResources\x12G\n\x10runtime_env_info\x18\x07 \x01(\x0b\x32\x1d.ray.rpc.ExportRuntimeEnvInfoR\x0eruntimeEnvInfo\x12\x1e\n\x08\x61\x63tor_id\x18\x08 \x01(\x0cH\x00R\x07\x61\x63torId\x88\x01\x01\x12\x31\n\x12placement_group_id\x18\t \x01(\x0cH\x01R\x10placementGroupId\x88\x01\x01\x12N\n\x06labels\x18\n \x03(\x0b\x32\x36.ray.rpc.ExportTaskEventData.TaskInfoEntry.LabelsEntryR\x06labels\x12\x64\n\x0elabel_selector\x18\x0b \x03(\x0b\x32=.ray.rpc.ExportTaskEventData.TaskInfoEntry.LabelSelectorEntryR\rlabelSelector\x1a\x44\n\x16RequiredResourcesEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\x01R\x05value:\x02\x38\x01\x1a\x39\n\x0bLabelsEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\x1a@\n\x12LabelSelectorEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\x42\x0b\n\t_actor_idB\x15\n\x13_placement_group_idB\x0c\n\n_task_infoB\x10\n\x0e_state_updatesB\x11\n\x0f_profile_eventsb\x06proto3')



_EXPORTTASKEVENTDATA = DESCRIPTOR.message_types_by_name['ExportTaskEventData']
_EXPORTTASKEVENTDATA_RAYERRORINFO = _EXPORTTASKEVENTDATA.nested_types_by_name['RayErrorInfo']
_EXPORTTASKEVENTDATA_TASKLOGINFO = _EXPORTTASKEVENTDATA.nested_types_by_name['TaskLogInfo']
_EXPORTTASKEVENTDATA_TASKSTATEUPDATE = _EXPORTTASKEVENTDATA.nested_types_by_name['TaskStateUpdate']
_EXPORTTASKEVENTDATA_TASKSTATEUPDATE_STATETSNSENTRY = _EXPORTTASKEVENTDATA_TASKSTATEUPDATE.nested_types_by_name['StateTsNsEntry']
_EXPORTTASKEVENTDATA_TASKINFOENTRY = _EXPORTTASKEVENTDATA.nested_types_by_name['TaskInfoEntry']
_EXPORTTASKEVENTDATA_TASKINFOENTRY_REQUIREDRESOURCESENTRY = _EXPORTTASKEVENTDATA_TASKINFOENTRY.nested_types_by_name['RequiredResourcesEntry']
_EXPORTTASKEVENTDATA_TASKINFOENTRY_LABELSENTRY = _EXPORTTASKEVENTDATA_TASKINFOENTRY.nested_types_by_name['LabelsEntry']
_EXPORTTASKEVENTDATA_TASKINFOENTRY_LABELSELECTORENTRY = _EXPORTTASKEVENTDATA_TASKINFOENTRY.nested_types_by_name['LabelSelectorEntry']
ExportTaskEventData = _reflection.GeneratedProtocolMessageType('ExportTaskEventData', (_message.Message,), {

  'RayErrorInfo' : _reflection.GeneratedProtocolMessageType('RayErrorInfo', (_message.Message,), {
    'DESCRIPTOR' : _EXPORTTASKEVENTDATA_RAYERRORINFO,
    '__module__' : 'src.ray.protobuf.export_task_event_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.ExportTaskEventData.RayErrorInfo)
    })
  ,

  'TaskLogInfo' : _reflection.GeneratedProtocolMessageType('TaskLogInfo', (_message.Message,), {
    'DESCRIPTOR' : _EXPORTTASKEVENTDATA_TASKLOGINFO,
    '__module__' : 'src.ray.protobuf.export_task_event_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.ExportTaskEventData.TaskLogInfo)
    })
  ,

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

    'StateTsNsEntry' : _reflection.GeneratedProtocolMessageType('StateTsNsEntry', (_message.Message,), {
      'DESCRIPTOR' : _EXPORTTASKEVENTDATA_TASKSTATEUPDATE_STATETSNSENTRY,
      '__module__' : 'src.ray.protobuf.export_task_event_pb2'
      # @@protoc_insertion_point(class_scope:ray.rpc.ExportTaskEventData.TaskStateUpdate.StateTsNsEntry)
      })
    ,
    'DESCRIPTOR' : _EXPORTTASKEVENTDATA_TASKSTATEUPDATE,
    '__module__' : 'src.ray.protobuf.export_task_event_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.ExportTaskEventData.TaskStateUpdate)
    })
  ,

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

    'RequiredResourcesEntry' : _reflection.GeneratedProtocolMessageType('RequiredResourcesEntry', (_message.Message,), {
      'DESCRIPTOR' : _EXPORTTASKEVENTDATA_TASKINFOENTRY_REQUIREDRESOURCESENTRY,
      '__module__' : 'src.ray.protobuf.export_task_event_pb2'
      # @@protoc_insertion_point(class_scope:ray.rpc.ExportTaskEventData.TaskInfoEntry.RequiredResourcesEntry)
      })
    ,

    'LabelsEntry' : _reflection.GeneratedProtocolMessageType('LabelsEntry', (_message.Message,), {
      'DESCRIPTOR' : _EXPORTTASKEVENTDATA_TASKINFOENTRY_LABELSENTRY,
      '__module__' : 'src.ray.protobuf.export_task_event_pb2'
      # @@protoc_insertion_point(class_scope:ray.rpc.ExportTaskEventData.TaskInfoEntry.LabelsEntry)
      })
    ,

    'LabelSelectorEntry' : _reflection.GeneratedProtocolMessageType('LabelSelectorEntry', (_message.Message,), {
      'DESCRIPTOR' : _EXPORTTASKEVENTDATA_TASKINFOENTRY_LABELSELECTORENTRY,
      '__module__' : 'src.ray.protobuf.export_task_event_pb2'
      # @@protoc_insertion_point(class_scope:ray.rpc.ExportTaskEventData.TaskInfoEntry.LabelSelectorEntry)
      })
    ,
    'DESCRIPTOR' : _EXPORTTASKEVENTDATA_TASKINFOENTRY,
    '__module__' : 'src.ray.protobuf.export_task_event_pb2'
    # @@protoc_insertion_point(class_scope:ray.rpc.ExportTaskEventData.TaskInfoEntry)
    })
  ,
  'DESCRIPTOR' : _EXPORTTASKEVENTDATA,
  '__module__' : 'src.ray.protobuf.export_task_event_pb2'
  # @@protoc_insertion_point(class_scope:ray.rpc.ExportTaskEventData)
  })
_sym_db.RegisterMessage(ExportTaskEventData)
_sym_db.RegisterMessage(ExportTaskEventData.RayErrorInfo)
_sym_db.RegisterMessage(ExportTaskEventData.TaskLogInfo)
_sym_db.RegisterMessage(ExportTaskEventData.TaskStateUpdate)
_sym_db.RegisterMessage(ExportTaskEventData.TaskStateUpdate.StateTsNsEntry)
_sym_db.RegisterMessage(ExportTaskEventData.TaskInfoEntry)
_sym_db.RegisterMessage(ExportTaskEventData.TaskInfoEntry.RequiredResourcesEntry)
_sym_db.RegisterMessage(ExportTaskEventData.TaskInfoEntry.LabelsEntry)
_sym_db.RegisterMessage(ExportTaskEventData.TaskInfoEntry.LabelSelectorEntry)

if _descriptor._USE_C_DESCRIPTORS == False:

  DESCRIPTOR._options = None
  _EXPORTTASKEVENTDATA_TASKSTATEUPDATE_STATETSNSENTRY._options = None
  _EXPORTTASKEVENTDATA_TASKSTATEUPDATE_STATETSNSENTRY._serialized_options = b'8\001'
  _EXPORTTASKEVENTDATA_TASKINFOENTRY_REQUIREDRESOURCESENTRY._options = None
  _EXPORTTASKEVENTDATA_TASKINFOENTRY_REQUIREDRESOURCESENTRY._serialized_options = b'8\001'
  _EXPORTTASKEVENTDATA_TASKINFOENTRY_LABELSENTRY._options = None
  _EXPORTTASKEVENTDATA_TASKINFOENTRY_LABELSENTRY._serialized_options = b'8\001'
  _EXPORTTASKEVENTDATA_TASKINFOENTRY_LABELSELECTORENTRY._options = None
  _EXPORTTASKEVENTDATA_TASKINFOENTRY_LABELSELECTORENTRY._serialized_options = b'8\001'
  _EXPORTTASKEVENTDATA._serialized_start=167
  _EXPORTTASKEVENTDATA._serialized_end=2484
  _EXPORTTASKEVENTDATA_RAYERRORINFO._serialized_start=511
  _EXPORTTASKEVENTDATA_RAYERRORINFO._serialized_end=613
  _EXPORTTASKEVENTDATA_TASKLOGINFO._serialized_start=616
  _EXPORTTASKEVENTDATA_TASKLOGINFO._serialized_end=953
  _EXPORTTASKEVENTDATA_TASKSTATEUPDATE._serialized_start=956
  _EXPORTTASKEVENTDATA_TASKSTATEUPDATE._serialized_end=1538
  _EXPORTTASKEVENTDATA_TASKSTATEUPDATE_STATETSNSENTRY._serialized_start=1381
  _EXPORTTASKEVENTDATA_TASKSTATEUPDATE_STATETSNSENTRY._serialized_end=1441
  _EXPORTTASKEVENTDATA_TASKINFOENTRY._serialized_start=1541
  _EXPORTTASKEVENTDATA_TASKINFOENTRY._serialized_end=2433
  _EXPORTTASKEVENTDATA_TASKINFOENTRY_REQUIREDRESOURCESENTRY._serialized_start=2204
  _EXPORTTASKEVENTDATA_TASKINFOENTRY_REQUIREDRESOURCESENTRY._serialized_end=2272
  _EXPORTTASKEVENTDATA_TASKINFOENTRY_LABELSENTRY._serialized_start=2274
  _EXPORTTASKEVENTDATA_TASKINFOENTRY_LABELSENTRY._serialized_end=2331
  _EXPORTTASKEVENTDATA_TASKINFOENTRY_LABELSELECTORENTRY._serialized_start=2333
  _EXPORTTASKEVENTDATA_TASKINFOENTRY_LABELSELECTORENTRY._serialized_end=2397
# @@protoc_insertion_point(module_scope)
emaballarin / ray python

Products

About

Resources

Contact Gemfury
