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

Mark the killed as done outside of loop (#1284)

Browse Source
This commit is contained in:
Stephanie Wang
2017-12-02 14:42:16 -08:00
committed by Philipp Moritz
parent c21e189371
commit 044548bcff
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/local_scheduler/local_scheduler_algorithm.cc
+6 -5
View File
@@ -415,11 +415,12 @@ void finish_killed_task(LocalSchedulerState *state,
ARROW_CHECK_OK(status);
ARROW_CHECK_OK(state->plasma_conn->Seal(object_id.to_plasma_id()));
}
if (state->db != NULL) {
Task *task = Task_alloc(spec, task_spec_size, TASK_STATUS_DONE,
get_db_client_id(state->db));
task_table_update(state->db, task, NULL, NULL, NULL);
}
}
/* Mark the task as done. */
if (state->db != NULL) {
Task *task = Task_alloc(spec, task_spec_size, TASK_STATUS_DONE,
get_db_client_id(state->db));
task_table_update(state->db, task, NULL, NULL, NULL);
}
}