ray.runtime_context.RuntimeContext.get_task_id#

RuntimeContext.get_task_id() → str | None[源代码]#

获取此工作者或驱动程序的当前任务ID。

任务ID是Ray任务的ID。ID将以十六进制格式显示。这不应该在驱动程序进程中使用。

示例

import ray

@ray.remote
class Actor:
    def get_task_id(self):
        return ray.get_runtime_context().get_task_id()

@ray.remote
def get_task_id():
    return ray.get_runtime_context().get_task_id()

# All the below code generates different task ids.
a = Actor.remote()
# Task ids are available for actor tasks.
print(ray.get(a.get_task_id.remote()))
# Task ids are available for normal tasks.
print(ray.get(get_task_id.remote()))

16310a0f0a45af5c2746a0e6efb235c0962896a201000000
c2668a65bda616c1ffffffffffffffffffffffff01000000

返回:: 当前工作者的任务ID，以十六进制表示。如果没有任务ID，则为None。