| 439 | DoneRemoteMapTask(); |
| 440 | } |
| 441 | void MRCommandComplete(bool isCanceled, TVector<TVector<char>>* res) override { |
| 442 | if (isCanceled) { |
| 443 | Cancel(); |
| 444 | return; |
| 445 | } |
| 446 | if (!NeedResult()) |
| 447 | return; |
| 448 | CopyRemoteTaskResults(LocalPartId, res); |
| 449 | if (AtomicGet(RemoteJobCount) > 0) { |
| 450 | // completed local part, lets try to execute all the rest map jobs locally |
| 451 | // "local-remote balance" |
| 452 | TryToExecAllMapsLocally(); |
| 453 | } |
| 454 | DoneRemoteMapTask(); |
| 455 | } |
| 456 | TGUID GetMasterQueryId() override { |
| 457 | return MasterGuid; |
| 458 | } |
no test coverage detected