@@ -485,6 +485,7 @@ void _starpu_handle_job_termination(struct _starpu_job *j)
* also the callback were executed. */
j->terminated = 2;
}
+ task->prefetched = 0;
STARPU_PTHREAD_COND_BROADCAST(&j->sync_cond);
STARPU_AYU_REMOVETASK(j->job_id);
STARPU_PTHREAD_MUTEX_UNLOCK(&j->sync_mutex);
@@ -740,7 +740,6 @@ static int _starpu_task_submit_head(struct starpu_task *task)
task->status = STARPU_TASK_INVALID;
else
STARPU_ASSERT(task->status == STARPU_TASK_INVALID);
- task->prefetched = 0;
if (j->internal)
{