| 113 | } |
| 114 | |
| 115 | void Worker::AbortStep(int64 step_id) { |
| 116 | Rendezvous* rendez = env_->rendezvous_mgr->Find(step_id); |
| 117 | SchedNonBlockingClosureAfter(1000000, [rendez, step_id]() { |
| 118 | // Delay a bit before aborting the step. This way, the root |
| 119 | // cause may return first back to the client instead of this |
| 120 | // cancellation generated abort error. |
| 121 | rendez->StartAbort(errors::Aborted("Step ", step_id, |
| 122 | " cancelled. Cancelling rendezvous.")); |
| 123 | rendez->Unref(); |
| 124 | }); |
| 125 | } |
| 126 | |
| 127 | Status Worker::PrepareRunGraph(RunGraphRequestWrapper* req, |
| 128 | GraphMgr::NamedTensors* in, |
nothing calls this directly
no test coverage detected