babymaker
e95a6a9342d4604277fe7cc6149b6b5b24447d89
|
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=") |
tuple resubmit.args = parser.parse_args() |
Definition at line 12 of file resubmit.py.
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') |
Definition at line 140 of file resubmit.py.
Referenced by utilities.addCommas(), addCommas(), mc_tools.getMomIndex(), weight_tools.getPDFWeights(), jet_met_tools.isLowDphi(), jet_met_tools.jetMatched(), main(), mergeNtuples(), bmaker_full.writeHiggVars(), bmaker_full.writeHLTObjects(), bmaker_full.writeLeptons(), bmaker_full.writeMC(), and bmaker_full.writePhotons().
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.
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.