ray.util.state.common.TaskState#

class ray.util.state.common.TaskState(task_id: str, attempt_number: int, name: str, state: Literal['NIL', 'PENDING_ARGS_AVAIL', 'PENDING_NODE_ASSIGNMENT', 'PENDING_OBJ_STORE_MEM_AVAIL', 'PENDING_ARGS_FETCH', 'SUBMITTED_TO_WORKER', 'RUNNING', 'RUNNING_IN_RAY_GET', 'RUNNING_IN_RAY_WAIT', 'FINISHED', 'FAILED'], job_id: str, actor_id: str | None, type: Literal['NORMAL_TASK', 'ACTOR_CREATION_TASK', 'ACTOR_TASK', 'DRIVER_TASK'], func_or_class_name: str, parent_task_id: str, node_id: str | None, worker_id: str | None, worker_pid: int | None, error_type: str | None, language: str | None = None, required_resources: dict | None = None, runtime_env_info: dict | None = None, placement_group_id: str | None = None, events: List[dict] | None = None, profiling_data: dict | None = None, creation_time_ms: int | None = None, start_time_ms: int | None = None, end_time_ms: int | None = None, task_log_info: dict | None = None, error_message: str | None = None, is_debugger_paused: bool | None = None)[源代码]#

基类：StateSchema

任务状态

以下列可以用于 --filter 选项。

尝试次数

任务ID

parent_task_id

actor_id

is_debugger_paused

类型

worker_id

错误类型

func_or_class_name

job_id

placement_group_id

名字

worker_pid

节点ID

语言

状态

以下列仅在使用 get API 时可用，

--detail 通过 CLI 指定，或者 detail=True 传递给 Python API。

actor_id

runtime_env_info

类型

worker_id

尝试次数

end_time_ms

错误类型

错误信息

节点ID

语言

任务ID

is_debugger_paused

profiling_data

creation_time_ms

worker_pid

事件

parent_task_id

start_time_ms

required_resources

func_or_class_name

任务日志信息

job_id

placement_group_id

名字

状态

task_id: str#: 任务的ID。

attempt_number: int#: 任务的重试次数。

name: str#: 如果由名称参数给出，则为任务的名称。

state: Literal['NIL', 'PENDING_ARGS_AVAIL', 'PENDING_NODE_ASSIGNMENT', 'PENDING_OBJ_STORE_MEM_AVAIL', 'PENDING_ARGS_FETCH', 'SUBMITTED_TO_WORKER', 'RUNNING', 'RUNNING_IN_RAY_GET', 'RUNNING_IN_RAY_WAIT', 'FINISHED', 'FAILED']#

任务的状态。

有关状态分解和典型状态转换流程的详细解释，请参阅 src/ray/protobuf/common.proto。

job_id: str#: 此任务的作业ID。

actor_id: str | None#: 与此任务关联的演员ID。如果没有相关演员，则为空。

type: Literal['NORMAL_TASK', 'ACTOR_CREATION_TASK', 'ACTOR_TASK', 'DRIVER_TASK']#

任务的类型。

NORMAL_TASK: 由 func.remote()` 创建的任务
ACTOR_CREATION_TASK: 由 class.remote() 创建的演员
ACTOR_TASK: 由 actor.method.remote() 提交的 Actor 任务
DRIVER_TASK: 驱动程序（调用 ray.init 的脚本）。

func_or_class_name: str#: 任务的名称。如果类型是任务或演员任务，则为函数名称。如果是演员调度任务，则为类名称。

parent_task_id: str#: 父任务ID。如果父任务是普通任务，它将是任务的ID。如果父任务在并发执行器（异步执行器或线程执行器）中运行，它将是执行器的创建任务ID。

node_id: str | None#: 运行任务的节点ID。如果任务被重试，它可能包含之前执行任务的节点ID。如果为空，意味着任务尚未被调度。

worker_id: str | None#: 与此任务关联的工人ID。

worker_pid: int | None#: 与此任务关联的工作进程的pid。

error_type: str | None#: 任务错误类型。

language: str | None = None#: 任务的语言。例如，Python、Java 或 Cpp。

required_resources: dict | None = None#: 执行任务所需的资源。

runtime_env_info: dict | None = None#: 任务的运行时环境信息。

placement_group_id: str | None = None#: 与此任务关联的放置组ID。

events: List[dict] | None = None#: 给定任务的事件列表。关于状态分解和典型状态转换流的详细解释，请参阅 src/ray/protobuf/common.proto。

profiling_data: dict | None = None#: 给定任务的配置文件事件列表。

creation_time_ms: int | None = None#: 任务创建的时间。一个以毫秒为单位的Unix时间戳。

start_time_ms: int | None = None#: 任务开始运行的时间。一个以毫秒为单位的Unix时间戳。

end_time_ms: int | None = None#: 任务完成或失败的时间。一个以毫秒为单位的Unix时间戳。

task_log_info: dict | None = None#: 任务日志信息，例如任务开始/结束时在工作者日志文件中的偏移量。如果任务来自并发执行者（例如异步执行者或线程执行者），则为None。

error_message: str | None = None#: 任务错误详细信息。