| 246 | return DCNotify->GetDistrCmdMasterQueryId(); |
| 247 | } |
| 248 | void LocalExec(int id) override { |
| 249 | if (!DCNotify->IsDistrCmdNeeded()) { |
| 250 | DoneJob(); |
| 251 | return; |
| 252 | } |
| 253 | TVector<char> buf; |
| 254 | buf.resize(sizeof(id)); |
| 255 | *(int*)&buf[0] = id; |
| 256 | SharedCmd->FinalMap->ExecAsync(Context.Get(), HostId, &buf, this, id); |
| 257 | } |
| 258 | ~TExecutor() override { |
| 259 | Y_ASSERT(JobCount == 0); |
| 260 | } |
nothing calls this directly
no test coverage detected