production_tasks Namespace Reference

Classes
class	BaseDataset
class	CheckConfig
class	CheckDatasetExists
class	CheckForMask
class	CheckForWrite
class	CheckJobStatus
class	CleanFiles
class	CleanJobFiles
class	CreateJobDirectory
class	ExpandConfig
class	FindOnCastor
class	FullCFG
class	GenerateMask
class	GZipFiles
class	MonitorJobs
class	ParseOptions
class	RunCMSBatch
class	RunTestEvents
class	SourceCFG
class	Task
class	WriteJobReport
class	WriteToDatasets

Functions
def	insertLines (insertedTo, toInsert)
def	mkdir_p (path)

Function Documentation

insertLines()

def production_tasks.insertLines	(		insertedTo,
			toInsert
	)

insert a sequence in another sequence.

the sequence is inserted either at the end, or at the position
of the HOOK, if it is found.
The HOOK is considered as being found if
  str(elem).find(###ProductionTaskHook$$$)
is true for one of the elements in the insertedTo sequence. 

Definition at line 355 of file production_tasks.py.

def insertLines( insertedTo, toInsert ):
    '''insert a sequence in another sequence.
 
    the sequence is inserted either at the end, or at the position
    of the HOOK, if it is found.
    The HOOK is considered as being found if
      str(elem).find(###ProductionTaskHook$$$)
    is true for one of the elements in the insertedTo sequence. 
    '''
    HOOK = '###ProductionTaskHook$$$'
    hookIndex = None
    for index, line in enumerate(insertedTo):
        line = str(line)
        if line.find(HOOK)>-1:
            hookIndex = index
            break        
    if hookIndex is not None:
        before = insertedTo[:hookIndex]
        after = insertedTo[hookIndex:]
        result = before + toInsert + after
        return result
    else:
        insertedTo.extend( toInsert )
        return insertedTo
 
    

References str.

Referenced by production_tasks.FullCFG.run(), and production_tasks.RunTestEvents.run().

mkdir_p()

def production_tasks.mkdir_p

(

path

)

Definition at line 19 of file production_tasks.py.

def mkdir_p(path):
    try:
        os.makedirs(path)
    except OSError as exc: # Python >2.5
        if exc.errno == errno.EEXIST:
            pass
        else: raise
 

Referenced by production_tasks.CreateJobDirectory.run().