|
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.
1.8.11