EL::Detail::SubmitManager Class Reference

#include <SubmitManager.h>

Inheritance diagram for EL::Detail::SubmitManager:

Collaboration diagram for EL::Detail::SubmitManager:

Public Member Functions
virtual std::pair< Detail::ManagerOrder, std::string >	getManagerOrder () const noexcept override
	get the order/name of this manager
virtual::StatusCode	doManagerStep (Detail::ManagerData &data) const override
	do whatever needs to be done for the given submission step

Detailed Description

Definition at line 20 of file SubmitManager.h.

Member Function Documentation

doManagerStep()

StatusCode EL::Detail::SubmitManager::doManagerStep ( Detail::ManagerData & data ) const

overridevirtual

do whatever needs to be done for the given submission step

Guarantee

basic

Failures

job configuration errors
driver errors

Implements EL::Detail::Manager.

Definition at line 47 of file SubmitManager.cxx.

    {
      switch (data.step)
      {
      case Detail::ManagerStep::initial:
        {
          if (data.resubmit)
            data.nextStep = Detail::ManagerStep::initialResubmit;
          else
            data.nextStep = Detail::ManagerStep::initialSubmit;
        }
        break;
 
      case Detail::ManagerStep::fillOptions:
        {
          data.options = *data.job->options();
          data.options.fetchDefaults (*data.driver->options());
        }
        break;
 
      case Detail::ManagerStep::addSystemAlgs:
        {
          if (data.options.castBool (Job::optDisableMetrics, false))
            if (!data.job->algsHas (MetricsSvc::name))
              data.job->algsAdd (new MetricsSvc);
        }
        break;
 
      case Detail::ManagerStep::prepareSubmitDir:
        {
          {
            std::unique_ptr<TFile> file (TFile::Open ((data.submitDir + "/driver.root").c_str(), "RECREATE"));
            if (file == nullptr || file->IsZombie())
            {
              ANA_MSG_ERROR ("failed to open " << data.submitDir << "/driver.root for writing");
              return ::StatusCode::FAILURE;
            }
            file->WriteObject (data.driver, "driver");
            file->Close ();
          }
          data.job->sampleHandler().save (data.submitDir + "/input");
          {
            std::ofstream file ((data.submitDir + "/location").c_str());
            file << data.submitDir << "\n";
          }
 
          SH::SampleHandler sh_hist;
          for (SH::Sample *sample : data.job->sampleHandler())
          {
            const std::string histfile
              = data.submitDir + "/hist-" + sample->name() + ".root";
            std::unique_ptr<SH::SampleHist> hist
              (new SH::SampleHist (sample->name(), histfile));
            hist->meta()->fetch (*sample->meta());
            sh_hist.add (std::move (hist));
          }
          sh_hist.save (data.submitDir + "/hist");
        }
        break;
 
      case Detail::ManagerStep::submitJob:
        {
          ANA_MSG_INFO ("submitting job in " << data.submitDir);
        }
        break;
 
      case Detail::ManagerStep::postSubmit:
        {
          if (!data.submitted)
          {
            ANA_MSG_FATAL ("Driver::submit not implemented in class " << typeid(*data.driver).name());
            std::abort ();
          }
 
          ANA_MSG_DEBUG ("make submitted");
          // this particular file can be checked to see if a job has
          // been submitted successfully.
          std::ofstream ((data.submitDir + "/submitted").c_str());
        }
        break;
 
      case Detail::ManagerStep::finalSubmit:
        {
          data.nextStep = Detail::ManagerStep::final;
        }
        break;
 
      case Detail::ManagerStep::finalResubmit:
        {
          if (!data.submitted)
          {
            ANA_MSG_FATAL ("Driver::resubmit not implemented in class " << typeid(*data.driver).name());
            std::abort ();
          }
 
          data.nextStep = Detail::ManagerStep::final;
        }
        break;
 
      default:
        (void) true; // safe to do nothing
      }
      return ::StatusCode::SUCCESS;
    }

getManagerOrder()

std::pair< Detail::ManagerOrder, std::string > EL::Detail::SubmitManager::getManagerOrder ( ) const

overridevirtualnoexcept

get the order/name of this manager

This is both used to identify the manager we are looking at, and to make sure they get executed in the right order. It is a mistake to load two managers that report the same order.

This is a pair of an enum that defines the absolute order of managers, and a string that identifies the stream that this manager belongs to. If this manager is not specific to a stream this should be the empty stream.

Guarantee

no-fail

Implements EL::Detail::Manager.

Definition at line 39 of file SubmitManager.cxx.

    {
      return std::make_pair (ManagerOrder::OPERATION, "");
    }

---

The documentation for this class was generated from the following files:

• SubmitManager.h
• SubmitManager.cxx