babymaker  e95a6a9342d4604277fe7cc6149b6b5b24447d89
Variables
resubmit Namespace Reference

Variables

tuple parser = argparse.ArgumentParser()
 
tuple args = parser.parse_args()
 
 timestamp = args.timestamp
 
 onePerJob = False
 
tuple host = os.environ.get("HOSTNAME")
 
 atUCSB = False
 
string redirector = "root://cms-xrd-global.cern.ch//"
 
tuple bdir = os.getcwd()
 
tuple logdir = os.path.join(bdir,'logs',timestamp)
 
tuple arxivdir = os.path.join(bdir,'logs',timestamp,'arxiv')
 
list loglist = [x for x in glob.glob(logdir+"/*.log")]
 
tuple failed = set()
 
tuple unfinished = set()
 
tuple xrootd_err = set()
 
tuple ferr = flog.rstrip(".log")
 
tuple fout = flog.rstrip(".log")
 
tuple bname = flog.split("/")
 
tuple logfile = open(flog)
 
tuple errfile = open(ferr)
 
tuple user_input = raw_input('Resubmit jobs [y/N]?')
 
int total_jobs = 0
 
tuple fexe = os.path.join(logdir.replace("/logs/","/run/"), old_baby+".sh")
 
tuple fcmd = os.path.join(logdir.replace("/logs/","/run/"), old_baby+".cmd")
 
tuple old_exe = open(fexe)
 
tuple new_exe = old_exe.replace("file:/hadoop/cms/phedex", redirector)
 
string sys_cmd = "condor_submit "
 
tuple tags = old_baby.split("_")
 
tuple batch = int(tags[-1].strip("batch"))
 
tuple nfiles = int(tags[-2].strip("mf"))
 
tuple old_cmd = open(fcmd)
 
list inputfiles = [line for line in old_exe if ("/store/" in line and "lcg-cp" not in line)]
 
string new_baby = old_baby+"_rs"
 
list new_exe_lines = [line for line in old_exe if ("/store/" not in line or "lcg-cp" in line)]
 
tuple ind = new_exe_lines.index('inputFiles=\\\n')
 
tuple new_cmd = old_cmd.replace(old_baby, new_baby)
 
tuple fnew_cmd = fcmd.replace(old_baby,new_baby)
 
tuple outputfile = line.split("SFN=")
 

Variable Documentation

tuple resubmit.args = parser.parse_args()

Definition at line 12 of file resubmit.py.

tuple resubmit.arxivdir = os.path.join(bdir,'logs',timestamp,'arxiv')

Definition at line 40 of file resubmit.py.

resubmit.atUCSB = False

Definition at line 25 of file resubmit.py.

tuple resubmit.batch = int(tags[-1].strip("batch"))

Definition at line 121 of file resubmit.py.

tuple resubmit.bdir = os.getcwd()

Definition at line 32 of file resubmit.py.

tuple resubmit.bname = flog.split("/")

Definition at line 55 of file resubmit.py.

tuple resubmit.errfile = open(ferr)

Definition at line 66 of file resubmit.py.

tuple resubmit.failed = set()

Definition at line 48 of file resubmit.py.

tuple resubmit.fcmd = os.path.join(logdir.replace("/logs/","/run/"), old_baby+".cmd")

Definition at line 106 of file resubmit.py.

tuple resubmit.ferr = flog.rstrip(".log")

Definition at line 53 of file resubmit.py.

tuple resubmit.fexe = os.path.join(logdir.replace("/logs/","/run/"), old_baby+".sh")

Definition at line 105 of file resubmit.py.

tuple resubmit.fnew_cmd = fcmd.replace(old_baby,new_baby)

Definition at line 146 of file resubmit.py.

tuple resubmit.fout = flog.rstrip(".log")

Definition at line 54 of file resubmit.py.

tuple resubmit.host = os.environ.get("HOSTNAME")

Definition at line 24 of file resubmit.py.

tuple resubmit.ind = new_exe_lines.index('inputFiles=\\\n')
list resubmit.inputfiles = [line for line in old_exe if ("/store/" in line and "lcg-cp" not in line)]

Definition at line 131 of file resubmit.py.

tuple resubmit.logdir = os.path.join(bdir,'logs',timestamp)

Definition at line 36 of file resubmit.py.

tuple resubmit.logfile = open(flog)

Definition at line 56 of file resubmit.py.

list resubmit.loglist = [x for x in glob.glob(logdir+"/*.log")]

Definition at line 45 of file resubmit.py.

string resubmit.new_baby = old_baby+"_rs"

Definition at line 138 of file resubmit.py.

tuple resubmit.new_cmd = old_cmd.replace(old_baby, new_baby)

Definition at line 145 of file resubmit.py.

tuple resubmit.new_exe = old_exe.replace("file:/hadoop/cms/phedex", redirector)

Definition at line 112 of file resubmit.py.

list resubmit.new_exe_lines = [line for line in old_exe if ("/store/" not in line or "lcg-cp" in line)]

Definition at line 139 of file resubmit.py.

tuple resubmit.nfiles = int(tags[-2].strip("mf"))

Definition at line 122 of file resubmit.py.

tuple resubmit.old_cmd = open(fcmd)

Definition at line 128 of file resubmit.py.

tuple resubmit.old_exe = open(fexe)

Definition at line 111 of file resubmit.py.

resubmit.onePerJob = False

Definition at line 21 of file resubmit.py.

tuple resubmit.outputfile = line.split("SFN=")

Definition at line 163 of file resubmit.py.

tuple resubmit.parser = argparse.ArgumentParser()

Definition at line 9 of file resubmit.py.

string resubmit.redirector = "root://cms-xrd-global.cern.ch//"

Definition at line 30 of file resubmit.py.

string resubmit.sys_cmd = "condor_submit "

Definition at line 114 of file resubmit.py.

tuple resubmit.tags = old_baby.split("_")

Definition at line 120 of file resubmit.py.

tuple resubmit.timestamp = args.timestamp

Definition at line 15 of file resubmit.py.

int resubmit.total_jobs = 0

Definition at line 103 of file resubmit.py.

tuple resubmit.unfinished = set()

Definition at line 49 of file resubmit.py.

tuple resubmit.user_input = raw_input('Resubmit jobs [y/N]?')

Definition at line 94 of file resubmit.py.

tuple resubmit.xrootd_err = set()

Definition at line 50 of file resubmit.py.