wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-07-06 02:30:52 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix driver id in TaskInfo (#5055)

Browse Source
This commit is contained in:
Hao Chen
2019-06-28 12:56:48 +08:00
committed by GitHub
parent a39982e676
commit cefbb0c94c
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ray/core_worker/common.h
+2 -2
View File
@@ -74,8 +74,8 @@ enum class TaskType { NORMAL_TASK, ACTOR_CREATION_TASK, ACTOR_TASK };
struct TaskInfo {
/// The ID of task.
const TaskID task_id;
/// The driver ID.
const DriverID driver_id;
/// The job ID.
const JobID job_id;
/// The type of task.
const TaskType task_type;
};
src/ray/core_worker/task_execution.cc
+1 -1
View File
@@ -46,7 +46,7 @@ Status CoreWorkerTaskExecutionInterface::Run(const TaskExecutor &executor) {
task_type = TaskType::NORMAL_TASK;
}
TaskInfo task_info{spec.TaskId(), spec.DriverId(), task_type};
TaskInfo task_info{spec.TaskId(), spec.JobId(), task_type};
auto num_returns = spec.NumReturns();
if (spec.IsActorCreationTask() || spec.IsActorTask()) {