Function LaunchJobRequest

library/cpp/par/par_exec.cpp:122–152

    }

    bool LaunchJobRequest(TJobRequest* jr, TRemoteQueryProcessor* queryProc, IUserContext* userContext, IMRCommandCompleteNotify* mrNotify) {
        Y_ASSERT(queryProc);
        Y_ASSERT(!jr->HostId2Computer.empty());
        int hostIdCount = jr->HostId2Computer.ysize();
        int localCompId = queryProc->GetCompId();

        THashMap<int, bool> allHostIdSet;
        bool hasAllHostIds = true;
        for (int i = 0; i < hostIdCount; ++i) {
            allHostIdSet[i];
            hasAllHostIds &= !jr->HostId2Computer[i].empty();
        }

        if (hasAllHostIds) {
            // has at least one remote comp for each hostId
            // try regular execution
            bool chk = ScheduleJobRequest(jr, queryProc);
            Y_ABORT_UNLESS(chk);

            TMRCommandExec::Launch(jr, queryProc, localCompId, userContext, mrNotify);
        } else {
            // not all hostIds are ready
            // lets check if we can execute locally
            if (!userContext->HasHostIds(allHostIdSet)) {
                // can not execute locally
                return false;
            }
            LaunchLocalJobRequest(jr, localCompId, userContext, mrNotify);
        }
        return true;
    }
}