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', 'PENDING_ACTOR_TASK_ARGS_FETCH', 'PENDING_ACTOR_TASK_ORDERING_OR_CONCURRENCY', '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, call_site: str | None = None, label_selector: dict | None = None)[source]#

Bases: StateSchema

Task State

Below columns can be used for the --filter option.

job_id

func_or_class_name

placement_group_id

error_type

language

type

parent_task_id

worker_pid

attempt_number

worker_id

actor_id

is_debugger_paused

name

task_id

node_id

state

Below columns are available only when get API is used,

--detail is specified through CLI, or detail=True is given to Python APIs.

creation_time_ms

error_type

profiling_data

worker_pid

worker_id

events

error_message

is_debugger_paused

name

language

job_id

actor_id

end_time_ms

task_log_info

required_resources

node_id

start_time_ms

type

parent_task_id

runtime_env_info

func_or_class_name

attempt_number

call_site

label_selector

state

task_id

placement_group_id

task_id: str#: The id of the task.

attempt_number: int#: The attempt (retry) number of the task.

name: str#: The name of the task if it is given by the name argument.

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

The state of the task.

Refer to src/ray/protobuf/common.proto for a detailed explanation of the state breakdowns and typical state transition flow.

job_id: str#: The job id of this task.

actor_id: str | None#: The actor id that’s associated with this task. It is empty if there’s no relevant actors.

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

The type of the task.

NORMAL_TASK: Tasks created by func.remote()`
ACTOR_CREATION_TASK: Actors created by class.remote()
ACTOR_TASK: Actor tasks submitted by actor.method.remote()
DRIVER_TASK: Driver (A script that calls ray.init).

func_or_class_name: str#: The name of the task. If is the name of the function if the type is a task or an actor task. It is the name of the class if it is a actor scheduling task.

parent_task_id: str#: The parent task id. If the parent is a normal task, it will be the task’s id. If the parent runs in a concurrent actor (async actor or threaded actor), it will be the actor’s creation task id.

node_id: str | None#: Id of the node that runs the task. If the task is retried, it could contain the node id of the previous executed task. If empty, it means the task hasn’t been scheduled yet.

worker_id: str | None#: The worker id that’s associated with this task.

worker_pid: int | None#: The worker’s pid that’s associated with this task.

error_type: str | None#: Task error type.

language: str | None = None#: The language of the task. E.g., Python, Java, or Cpp.

required_resources: dict | None = None#: The required resources to execute the task.

runtime_env_info: dict | None = None#: The runtime environment information for the task.

placement_group_id: str | None = None#: The placement group id that’s associated with this task.

events: List[dict] | None = None#: The list of events of the given task. Refer to src/ray/protobuf/common.proto for a detailed explanation of the state breakdowns and typical state transition flow.

profiling_data: dict | None = None#: The list of profile events of the given task.

creation_time_ms: int | None = None#: The time when the task is created. A Unix timestamp in ms.

start_time_ms: int | None = None#: The time when the task starts to run. A Unix timestamp in ms.

end_time_ms: int | None = None#: The time when the task is finished or failed. A Unix timestamp in ms.

task_log_info: dict | None = None#: The task logs info, e.g. offset into the worker log file when the task starts/finishes. None if the task is from a concurrent actor (e.g. async actor or threaded actor)

error_message: str | None = None#: Task error detail info.

call_site: str | None = None#: The call site of the task.

label_selector: dict | None = None#: The label selector for the task.