sherpaTarCreator.htcondor_lxplus Namespace Reference

Classes
class	batchJob

Functions
def	finalizeJobs (dryRun)

Variables
list	joblist = []
dictionary	dependencelist = {}

Function Documentation

finalizeJobs()

def sherpaTarCreator.htcondor_lxplus.finalizeJobs

(

dryRun

)

Definition at line 38 of file htcondor_lxplus.py.

def finalizeJobs(dryRun):
 
    #create dagfile
    dagfile = ""
    for job in joblist:
        dagfile += "JOB "+job.id+" "+job.basedir+"/"+job.name+".sub\n"
 
    for parent,children in dependencelist.items():
        dagfile += "PARENT "+parent+" CHILD"
        for child in children:
            dagfile += " "+child
        dagfile += "\n"
 
    #save file
    with open("dagfile.dag", 'w') as f:
        f.write(dagfile)
 
    #submit job
    batchname = os.path.basename(os.path.normpath(os.getcwd()))
    cmd = "condor_submit_dag -force -batch-name "+batchname+" dagfile.dag"
 
    if dryRun:
        print (cmd+"\n")
        print ("dagfile: \n"+dagfile)
    else:
        print (cmd)
        p = subprocess.Popen(cmd,shell=True,stdout=subprocess.PIPE,stderr=subprocess.PIPE)
        retcode = p.communicate()
        if len(retcode[0]):
            print (retcode[0].decode('utf-8'))
        if len(retcode[1]):
            print (retcode[1].decode('utf-8'))
        if p.returncode:
            print ("ERROR: error while submitting job")
            print ("return code: " + str(p.returncode))
            sys.exit(11)
 

Variable Documentation

dependencelist

dictionary sherpaTarCreator.htcondor_lxplus.dependencelist = {}

Definition at line 6 of file htcondor_lxplus.py.

joblist

list sherpaTarCreator.htcondor_lxplus.joblist = []

Definition at line 5 of file htcondor_lxplus.py.