ray.util.state.common.TaskSummaryPerFuncOrClassName#

class ray.util.state.common.TaskSummaryPerFuncOrClassName(func_or_class_name: str, type: str, state_counts: ~typing.Dict[~typing.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'], int] = <factory>)[源代码]#

基类:object

func_or_class_name: str#

此任务的函数或类名。

type: str#

类的类型。等同于 protobuf 的 TaskType。

state_counts: Dict[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'], int]#

将状态名称添加到计数字典中。状态名称等同于protobuf的TaskStatus。