@@ -209,6 +209,8 @@ void *_starpu_cpu_worker(void *arg)
if (rank == 0)
_starpu_handle_job_termination(j);
+ else
+ _starpu_sched_post_exec_hook(j->task);
}
_STARPU_TRACE_WORKER_DEINIT_START
@@ -39,8 +39,7 @@ void _starpu_driver_start_job(struct _starpu_worker *args, struct _starpu_job *j
if (cl->model && cl->model->benchmarking)
calibrate_model = 1;
- if (rank == 0)
- _starpu_sched_pre_exec_hook(task);
+ _starpu_sched_pre_exec_hook(task);
args->status = STATUS_EXECUTING;
task->status = STARPU_TASK_RUNNING;