Function LaunchLocalJobRequest

library/cpp/par/par_exec.cpp:107–120

    }

    void LaunchLocalJobRequest(TJobRequest* jr, int localCompId, IUserContext* userContext, IMRCommandCompleteNotify* mrNotify) {
        int hostIdCount = userContext->GetHostIdCount();
        jr->HostId2Computer.resize(0);
        jr->HostId2Computer.resize(hostIdCount);

        int mapJobCount = jr->Descr.ExecList.ysize();
        for (int i = 0; i < mapJobCount; ++i) {
            TJobParams& params = jr->Descr.ExecList[i];
            params.CompId = localCompId;
        }
        jr->ExecPlan.resize(0); // empty execplan means execute locally

        TMRCommandExec::Launch(jr, nullptr, localCompId, userContext, mrNotify);
    }

    bool LaunchJobRequest(TJobRequest* jr, TRemoteQueryProcessor* queryProc, IUserContext* userContext, IMRCommandCompleteNotify* mrNotify) {
        Y_ASSERT(queryProc);