Home
last modified time | relevance | path

Searched refs:tasks_by_job_ (Results 1 – 2 of 2) sorted by relevance

/external/tensorflow/tensorflow/core/data/service/
Ddispatcher_state.cc106 tasks_by_job_[job_id] = std::vector<std::shared_ptr<Task>>(); in CreateJob()
180 tasks_by_job_[job->job_id].push_back(task.task); in ClientHeartbeat()
194 tasks_by_job_[create_task.job_id()].push_back(task); in CreateTask()
207 for (const auto& task_for_job : tasks_by_job_[task->job->job_id]) { in FinishTask()
320 auto it = tasks_by_job_.find(job_id); in TasksForJob()
321 if (it == tasks_by_job_.end()) { in TasksForJob()
Ddispatcher_state.h249 absl::flat_hash_map<int64, std::vector<std::shared_ptr<Task>>> tasks_by_job_; variable