| 154 | CancelCallback.Attach(this, queryProc, ReqId); |
| 155 | } |
| 156 | ~TRemoteMRCommandExec() override { |
| 157 | CancelCallback.Detach(); |
| 158 | } |
| 159 | void LaunchRequest(TContextReplica* context) { |
| 160 | if (context->GetContextState(AllJobs->EnvId2Version, &ContextData)) { |
| 161 | UserContext = new TUserContext(QueryProc.Get(), AllJobs.Get(), &ContextData, context->GetWriteBuffer()); |