MinosRSMTask.py

Go to the documentation of this file.

import re

from GBSTask import GBSTask

def IsValidJobName(name):
    """Class method to check that job name is of form job_rrrrrrrr_ssss"""

    if re.search(r"job_\d{8}_\d{4}",name): return True
    print "Sorry, job name " + name + " is not valid.  It should take the form: job_rrrrrrrr_ssss"
    return False


class MinosRSMTask(GBSTask) :
    """Top level object to manage a single task.

    This class inherits from GBSTask and adds the constraint that Job and ProtoJob names
    must be of the form:-

      job_rrrrrrrr_ssss

      where

        rrrrrrrr  is an 8 digit zero padded run number
        ssss      is a 4 digit zero padded subrun number

    It manages Monte Carlo jobs in which the run and subrun numbers
    determine the Monte Carlo random number seed and introduces the
    new method

      RenameJob(old_name, new_name)

    which allows a job to use a seed.
    """

    ######  GBSObject inherited responsibilities   ###### 
      

    def __init__(self,name,parent,model,model_args):
        GBSTask.__init__(self,name,parent,model,model_args)

    def _DoMemberIO(self,ioh):
        GBSTask._DoMemberIO(self,ioh)

    def GetType(self): return "MinosRSMTask"

    def __repr__(self) : return self.AsString()
    
    ######  User Callable Methods (Getters then Setters)  ###### 
    


    ######  Private Methods (not user callable)  ######

    def _AddJobOrProtoJob(self,job_name,args_str,env_str,type):

       """Create a new named Job or ProtoJob and optionally assign its application script local args."""
       if not IsValidJobName(job_name): return None
       return GBSTask._AddJobOrProtoJob(self,job_name,args_str,env_str,type)

    def RenameJob(self,old_name,new_name):
       """Rename job from old_name to new_name."""
       if not IsValidJobName(new_name): return
       job = self.GetJob(old_name)
       if not job: return
       if self.GetJob(new_name,False):
           print "Sorry, there already is a job named " + new_name
           return
       job._Rename(new_name)
       del self._jobManagers[old_name]
       self._jobManagers[new_name] = job

---